async

package module
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 3, 2020 License: GPL-3.0 Imports: 14 Imported by: 5

README

async

Go API & libraries for working with SLCT runtime, that allow Go developers to share asynchronous code (for example send message to Slack and return user input) with consistency and "only-once" processing guarantees.

Usage

package main

import (
	"log"
	"github.com/gladkikhartem/async"
	"google.golang.org/grpc"
)

var defs = async.Definitions{
	"counter": async.StandardDefinition(CounterProcess{}),
}

type CounterProcess struct {
	Counter int64
}

func (c *CounterProcess) Main_Count(p *async.Process) error {
    c.Counter++
    p.Recv("counter").To(c.Main_Count).
        .After(time.Hour).To(c.Main_Done)
    return nil
}

func (c *CounterProcess) Main_Done(p *async.Process) error {
    log.Print("done")
    return nil
}

func main() {
    conn, err := grpc.Dial("runtime_addr:9090", grpc.WithInsecure())
	if err != nil {
		log.Fatal(err)
	}
    defer conn.Close()
    
	err := async.ManageDefs(context.Background(), conn, "1", defs)
    if err != nil {
        log.Fatal(err)
    }
}

Architecture

Asynchronous process is described as set of goroutines(FSM) with a shared state. In the code it's represented as Go struct with methods in a format {GoroutineName_FSMStatus}.

type ExampleProcess struct {
    // local variables  i.e. state
}

func (c *ExampleProcess) Main_Start(p *async.Process) error { 
    p.Go(c.Goroutine1_Start) // run parallel process in this state
	return slack.Approve(p, c.Main_CheckApprove, "Approve?", time.Hour)
}

func (c *ExampleProcess) Main_CheckApprove(p *async.Process, result slack.Result) error {
	// handle approval result
}

func (c *ExampleProcess) Goroutine1_Start(p *async.Process) error { 
    // ... 
}

When async process is resumed:

  • Current state is unmarshalled into struct
  • Correct method is called to continue goroutine execution .
  • Method executes, updates the state and specifies conditions on when to unblock current goroutine. (New goroutines can also be created during execution)
  • Updated state is saved in runtime.

Method can specify following unblocking conditions (same as in Go):

  • send/recv on channel
  • send/recv on buffered channel
  • recv on <-time.After channel
  • default statement
  • handling of channel close
  • cases are evaluated in sequential order

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Case_Op_name = map[int32]string{
	0: "Invalid",
	1: "Send",
	2: "Recv",
	3: "Time",
	5: "Default",
}
View Source 
var Case_Op_value = map[string]int32{
	"Invalid": 0,
	"Send":    1,
	"Recv":    2,
	"Time":    3,
	"Default": 5,
}
View Source 
var Process_Status_name = map[int32]string{
	0: "Invalid",
	1: "Started",
	2: "Running",
	3: "Finished",
}
View Source 
var Process_Status_value = map[string]int32{
	"Invalid":  0,
	"Started":  1,
	"Running":  2,
	"Finished": 3,
}
View Source 
var Select_Result_name = map[int32]string{
	0: "Invalid",
	1: "OK",
	2: "Closed",
}
View Source 
var Select_Result_value = map[string]int32{
	"Invalid": 0,
	"OK":      1,
	"Closed":  2,
}
View Source 
var Thread_Status_name = map[int32]string{
	0: "Invalid",
	1: "Blocked",
	2: "Unblocked",
	3: "Aborted",
}
View Source 
var Thread_Status_value = map[string]int32{
	"Invalid":   0,
	"Blocked":   1,
	"Unblocked": 2,
	"Aborted":   3,
}

Functions

func GetFunctionName 

func GetFunctionName(i interface{}) string

func Manage 

func Manage(ctx context.Context, client RuntimeClient, ss ...Service) error

func RegisterRuntimeServer 

func RegisterRuntimeServer(s *grpc.Server, srv RuntimeServer)

Types

type API 

type API struct {
	API          *ProcessAPI
	NewProcState func() interface{}
}

type AsyncType 

type AsyncType interface {
	Type() *Type
}

type BufData 

type BufData struct {
	//string Process     = 1;
	//string Select    = 2;
	//string Group     = 3;
	//string ToStatus  = 4;
	Chan                 string   `protobuf:"bytes,1,opt,name=Chan,proto3" json:"Chan,omitempty"`
	Data                 []byte   `protobuf:"bytes,5,opt,name=Data,proto3" json:"Data,omitempty"`
	Clock                uint64   `protobuf:"varint,6,opt,name=clock,proto3" json:"clock,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BufData) Descriptor 

func (*BufData) Descriptor() ([]byte, []int)

func (*BufData) GetChan 

func (m *BufData) GetChan() string

func (*BufData) GetClock 

func (m *BufData) GetClock() uint64

func (*BufData) GetData 

func (m *BufData) GetData() []byte

func (*BufData) ProtoMessage 

func (*BufData) ProtoMessage()

func (*BufData) Reset 

func (m *BufData) Reset()

func (*BufData) String 

func (m *BufData) String() string

func (*BufData) XXX_DiscardUnknown 

func (m *BufData) XXX_DiscardUnknown()

func (*BufData) XXX_Marshal 

func (m *BufData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BufData) XXX_Merge 

func (m *BufData) XXX_Merge(src proto.Message)

func (*BufData) XXX_Size 

func (m *BufData) XXX_Size() int

func (*BufData) XXX_Unmarshal 

func (m *BufData) XXX_Unmarshal(b []byte) error

type Call 

type Call struct {
	Id         string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name       string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Input      []byte `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	InputType  string `protobuf:"bytes,4,opt,name=inputType,proto3" json:"inputType,omitempty"`
	OutputType string `protobuf:"bytes,5,opt,name=outputType,proto3" json:"outputType,omitempty"`
	// filled after unblocked
	Output               []byte   `protobuf:"bytes,6,opt,name=output,proto3" json:"output,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Call) Descriptor 

func (*Call) Descriptor() ([]byte, []int)

func (*Call) GetId 

func (m *Call) GetId() string

func (*Call) GetInput 

func (m *Call) GetInput() []byte

func (*Call) GetInputType 

func (m *Call) GetInputType() string

func (*Call) GetName 

func (m *Call) GetName() string

func (*Call) GetOutput 

func (m *Call) GetOutput() []byte

func (*Call) GetOutputType 

func (m *Call) GetOutputType() string

func (*Call) ProtoMessage 

func (*Call) ProtoMessage()

func (*Call) Reset 

func (m *Call) Reset()

func (*Call) String 

func (m *Call) String() string

func (*Call) XXX_DiscardUnknown 

func (m *Call) XXX_DiscardUnknown()

func (*Call) XXX_Marshal 

func (m *Call) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Call) XXX_Merge 

func (m *Call) XXX_Merge(src proto.Message)

func (*Call) XXX_Size 

func (m *Call) XXX_Size() int

func (*Call) XXX_Unmarshal 

func (m *Call) XXX_Unmarshal(b []byte) error

type Case 

type Case struct {
	ToStatus             string   `protobuf:"bytes,1,opt,name=toStatus,proto3" json:"toStatus,omitempty"`
	Op                   Case_Op  `protobuf:"varint,2,opt,name=op,proto3,enum=async.Case_Op" json:"op,omitempty"`
	Chan                 string   `protobuf:"bytes,3,opt,name=chan,proto3" json:"chan,omitempty"`
	Time                 uint64   `protobuf:"varint,4,opt,name=time,proto3" json:"time,omitempty"`
	Data                 []byte   `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
	DataType             string   `protobuf:"bytes,6,opt,name=dataType,proto3" json:"dataType,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Case) Descriptor 

func (*Case) Descriptor() ([]byte, []int)

func (*Case) GetChan 

func (m *Case) GetChan() string

func (*Case) GetData 

func (m *Case) GetData() []byte

func (*Case) GetDataType 

func (m *Case) GetDataType() string

func (*Case) GetOp 

func (m *Case) GetOp() Case_Op

func (*Case) GetTime 

func (m *Case) GetTime() uint64

func (*Case) GetToStatus 

func (m *Case) GetToStatus() string

func (*Case) ProtoMessage 

func (*Case) ProtoMessage()

func (*Case) Reset 

func (m *Case) Reset()

func (*Case) String 

func (m *Case) String() string

func (*Case) XXX_DiscardUnknown 

func (m *Case) XXX_DiscardUnknown()

func (*Case) XXX_Marshal 

func (m *Case) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Case) XXX_Merge 

func (m *Case) XXX_Merge(src proto.Message)

func (*Case) XXX_Size 

func (m *Case) XXX_Size() int

func (*Case) XXX_Unmarshal 

func (m *Case) XXX_Unmarshal(b []byte) error

type Case_Op 

type Case_Op int32
const (
	Case_Invalid Case_Op = 0
	Case_Send    Case_Op = 1
	Case_Recv    Case_Op = 2
	Case_Time    Case_Op = 3
	Case_Default Case_Op = 5
)

func (Case_Op) EnumDescriptor 

func (Case_Op) EnumDescriptor() ([]byte, []int)

func (Case_Op) String 

func (x Case_Op) String() string

type ChanSelect 

type ChanSelect struct {
	BlockedAt            uint64   `protobuf:"varint,1,opt,name=blockedAt,proto3" json:"blockedAt,omitempty"`
	Case                 uint64   `protobuf:"varint,2,opt,name=case,proto3" json:"case,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ChanSelect) Descriptor 

func (*ChanSelect) Descriptor() ([]byte, []int)

func (*ChanSelect) GetBlockedAt 

func (m *ChanSelect) GetBlockedAt() uint64

func (*ChanSelect) GetCase 

func (m *ChanSelect) GetCase() uint64

func (*ChanSelect) ProtoMessage 

func (*ChanSelect) ProtoMessage()

func (*ChanSelect) Reset 

func (m *ChanSelect) Reset()

func (*ChanSelect) String 

func (m *ChanSelect) String() string

func (*ChanSelect) XXX_DiscardUnknown 

func (m *ChanSelect) XXX_DiscardUnknown()

func (*ChanSelect) XXX_Marshal 

func (m *ChanSelect) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChanSelect) XXX_Merge 

func (m *ChanSelect) XXX_Merge(src proto.Message)

func (*ChanSelect) XXX_Size 

func (m *ChanSelect) XXX_Size() int

func (*ChanSelect) XXX_Unmarshal 

func (m *ChanSelect) XXX_Unmarshal(b []byte) error

type Channel 

type Channel struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	DataType             string   `protobuf:"bytes,2,opt,name=dataType,proto3" json:"dataType,omitempty"`
	Closed               bool     `protobuf:"varint,3,opt,name=closed,proto3" json:"closed,omitempty"`
	BufSize              uint64   `protobuf:"varint,4,opt,name=bufSize,proto3" json:"bufSize,omitempty"`
	BufMaxSize           uint64   `protobuf:"varint,5,opt,name=bufMaxSize,proto3" json:"bufMaxSize,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Channel) Descriptor 

func (*Channel) Descriptor() ([]byte, []int)

func (*Channel) GetBufMaxSize 

func (m *Channel) GetBufMaxSize() uint64

func (*Channel) GetBufSize 

func (m *Channel) GetBufSize() uint64

func (*Channel) GetClosed 

func (m *Channel) GetClosed() bool

func (*Channel) GetDataType 

func (m *Channel) GetDataType() string

func (*Channel) GetId 

func (m *Channel) GetId() string

func (*Channel) ProtoMessage 

func (*Channel) ProtoMessage()

func (*Channel) Reset 

func (m *Channel) Reset()

func (*Channel) String 

func (m *Channel) String() string

func (*Channel) XXX_DiscardUnknown 

func (m *Channel) XXX_DiscardUnknown()

func (*Channel) XXX_Marshal 

func (m *Channel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Channel) XXX_Merge 

func (m *Channel) XXX_Merge(src proto.Message)

func (*Channel) XXX_Size 

func (m *Channel) XXX_Size() int

func (*Channel) XXX_Unmarshal 

func (m *Channel) XXX_Unmarshal(b []byte) error

type CloseChanReq 

type CloseChanReq struct {
	Ids                  []string `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CloseChanReq) Descriptor 

func (*CloseChanReq) Descriptor() ([]byte, []int)

func (*CloseChanReq) GetIds 

func (m *CloseChanReq) GetIds() []string

func (*CloseChanReq) ProtoMessage 

func (*CloseChanReq) ProtoMessage()

func (*CloseChanReq) Reset 

func (m *CloseChanReq) Reset()

func (*CloseChanReq) String 

func (m *CloseChanReq) String() string

func (*CloseChanReq) XXX_DiscardUnknown 

func (m *CloseChanReq) XXX_DiscardUnknown()

func (*CloseChanReq) XXX_Marshal 

func (m *CloseChanReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CloseChanReq) XXX_Merge 

func (m *CloseChanReq) XXX_Merge(src proto.Message)

func (*CloseChanReq) XXX_Size 

func (m *CloseChanReq) XXX_Size() int

func (*CloseChanReq) XXX_Unmarshal 

func (m *CloseChanReq) XXX_Unmarshal(b []byte) error

type Empty 

type Empty struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Empty) Descriptor 

func (*Empty) Descriptor() ([]byte, []int)

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) String 

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal 

func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Empty) XXX_Merge 

func (m *Empty) XXX_Merge(src proto.Message)

func (*Empty) XXX_Size 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal 

func (m *Empty) XXX_Unmarshal(b []byte) error

type GetProcessReq 

type GetProcessReq struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetProcessReq) Descriptor 

func (*GetProcessReq) Descriptor() ([]byte, []int)

func (*GetProcessReq) GetId 

func (m *GetProcessReq) GetId() string

func (*GetProcessReq) ProtoMessage 

func (*GetProcessReq) ProtoMessage()

func (*GetProcessReq) Reset 

func (m *GetProcessReq) Reset()

func (*GetProcessReq) String 

func (m *GetProcessReq) String() string

func (*GetProcessReq) XXX_DiscardUnknown 

func (m *GetProcessReq) XXX_DiscardUnknown()

func (*GetProcessReq) XXX_Marshal 

func (m *GetProcessReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetProcessReq) XXX_Merge 

func (m *GetProcessReq) XXX_Merge(src proto.Message)

func (*GetProcessReq) XXX_Size 

func (m *GetProcessReq) XXX_Size() int

func (*GetProcessReq) XXX_Unmarshal 

func (m *GetProcessReq) XXX_Unmarshal(b []byte) error

type ListAPIsReq 

type ListAPIsReq struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	From                 string   `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"`
	Limit                uint64   `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListAPIsReq) Descriptor 

func (*ListAPIsReq) Descriptor() ([]byte, []int)

func (*ListAPIsReq) GetFrom 

func (m *ListAPIsReq) GetFrom() string

func (*ListAPIsReq) GetId 

func (m *ListAPIsReq) GetId() string

func (*ListAPIsReq) GetLimit 

func (m *ListAPIsReq) GetLimit() uint64

func (*ListAPIsReq) ProtoMessage 

func (*ListAPIsReq) ProtoMessage()

func (*ListAPIsReq) Reset 

func (m *ListAPIsReq) Reset()

func (*ListAPIsReq) String 

func (m *ListAPIsReq) String() string

func (*ListAPIsReq) XXX_DiscardUnknown 

func (m *ListAPIsReq) XXX_DiscardUnknown()

func (*ListAPIsReq) XXX_Marshal 

func (m *ListAPIsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListAPIsReq) XXX_Merge 

func (m *ListAPIsReq) XXX_Merge(src proto.Message)

func (*ListAPIsReq) XXX_Size 

func (m *ListAPIsReq) XXX_Size() int

func (*ListAPIsReq) XXX_Unmarshal 

func (m *ListAPIsReq) XXX_Unmarshal(b []byte) error

type ListAPIsResp 

type ListAPIsResp struct {
	Apis                 []*ProcessAPI `protobuf:"bytes,1,rep,name=apis,proto3" json:"apis,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ListAPIsResp) Descriptor 

func (*ListAPIsResp) Descriptor() ([]byte, []int)

func (*ListAPIsResp) GetApis 

func (m *ListAPIsResp) GetApis() []*ProcessAPI

func (*ListAPIsResp) ProtoMessage 

func (*ListAPIsResp) ProtoMessage()

func (*ListAPIsResp) Reset 

func (m *ListAPIsResp) Reset()

func (*ListAPIsResp) String 

func (m *ListAPIsResp) String() string

func (*ListAPIsResp) XXX_DiscardUnknown 

func (m *ListAPIsResp) XXX_DiscardUnknown()

func (*ListAPIsResp) XXX_Marshal 

func (m *ListAPIsResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListAPIsResp) XXX_Merge 

func (m *ListAPIsResp) XXX_Merge(src proto.Message)

func (*ListAPIsResp) XXX_Size 

func (m *ListAPIsResp) XXX_Size() int

func (*ListAPIsResp) XXX_Unmarshal 

func (m *ListAPIsResp) XXX_Unmarshal(b []byte) error

type ListChansReq 

type ListChansReq struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	From                 string   `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"`
	Limit                uint64   `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListChansReq) Descriptor 

func (*ListChansReq) Descriptor() ([]byte, []int)

func (*ListChansReq) GetFrom 

func (m *ListChansReq) GetFrom() string

func (*ListChansReq) GetId 

func (m *ListChansReq) GetId() string

func (*ListChansReq) GetLimit 

func (m *ListChansReq) GetLimit() uint64

func (*ListChansReq) ProtoMessage 

func (*ListChansReq) ProtoMessage()

func (*ListChansReq) Reset 

func (m *ListChansReq) Reset()

func (*ListChansReq) String 

func (m *ListChansReq) String() string

func (*ListChansReq) XXX_DiscardUnknown 

func (m *ListChansReq) XXX_DiscardUnknown()

func (*ListChansReq) XXX_Marshal 

func (m *ListChansReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListChansReq) XXX_Merge 

func (m *ListChansReq) XXX_Merge(src proto.Message)

func (*ListChansReq) XXX_Size 

func (m *ListChansReq) XXX_Size() int

func (*ListChansReq) XXX_Unmarshal 

func (m *ListChansReq) XXX_Unmarshal(b []byte) error

type ListChansResp 

type ListChansResp struct {
	Chans                []*Channel `protobuf:"bytes,1,rep,name=chans,proto3" json:"chans,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*ListChansResp) Descriptor 

func (*ListChansResp) Descriptor() ([]byte, []int)

func (*ListChansResp) GetChans 

func (m *ListChansResp) GetChans() []*Channel

func (*ListChansResp) ProtoMessage 

func (*ListChansResp) ProtoMessage()

func (*ListChansResp) Reset 

func (m *ListChansResp) Reset()

func (*ListChansResp) String 

func (m *ListChansResp) String() string

func (*ListChansResp) XXX_DiscardUnknown 

func (m *ListChansResp) XXX_DiscardUnknown()

func (*ListChansResp) XXX_Marshal 

func (m *ListChansResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListChansResp) XXX_Merge 

func (m *ListChansResp) XXX_Merge(src proto.Message)

func (*ListChansResp) XXX_Size 

func (m *ListChansResp) XXX_Size() int

func (*ListChansResp) XXX_Unmarshal 

func (m *ListChansResp) XXX_Unmarshal(b []byte) error

type ListTypesReq 

type ListTypesReq struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	From                 string   `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"`
	Limit                uint64   `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListTypesReq) Descriptor 

func (*ListTypesReq) Descriptor() ([]byte, []int)

func (*ListTypesReq) GetFrom 

func (m *ListTypesReq) GetFrom() string

func (*ListTypesReq) GetId 

func (m *ListTypesReq) GetId() string

func (*ListTypesReq) GetLimit 

func (m *ListTypesReq) GetLimit() uint64

func (*ListTypesReq) ProtoMessage 

func (*ListTypesReq) ProtoMessage()

func (*ListTypesReq) Reset 

func (m *ListTypesReq) Reset()

func (*ListTypesReq) String 

func (m *ListTypesReq) String() string

func (*ListTypesReq) XXX_DiscardUnknown 

func (m *ListTypesReq) XXX_DiscardUnknown()

func (*ListTypesReq) XXX_Marshal 

func (m *ListTypesReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListTypesReq) XXX_Merge 

func (m *ListTypesReq) XXX_Merge(src proto.Message)

func (*ListTypesReq) XXX_Size 

func (m *ListTypesReq) XXX_Size() int

func (*ListTypesReq) XXX_Unmarshal 

func (m *ListTypesReq) XXX_Unmarshal(b []byte) error

type ListTypesResp 

type ListTypesResp struct {
	Types                []*Type  `protobuf:"bytes,1,rep,name=types,proto3" json:"types,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListTypesResp) Descriptor 

func (*ListTypesResp) Descriptor() ([]byte, []int)

func (*ListTypesResp) GetTypes 

func (m *ListTypesResp) GetTypes() []*Type

func (*ListTypesResp) ProtoMessage 

func (*ListTypesResp) ProtoMessage()

func (*ListTypesResp) Reset 

func (m *ListTypesResp) Reset()

func (*ListTypesResp) String 

func (m *ListTypesResp) String() string

func (*ListTypesResp) XXX_DiscardUnknown 

func (m *ListTypesResp) XXX_DiscardUnknown()

func (*ListTypesResp) XXX_Marshal 

func (m *ListTypesResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListTypesResp) XXX_Merge 

func (m *ListTypesResp) XXX_Merge(src proto.Message)

func (*ListTypesResp) XXX_Size 

func (m *ListTypesResp) XXX_Size() int

func (*ListTypesResp) XXX_Unmarshal 

func (m *ListTypesResp) XXX_Unmarshal(b []byte) error

type ListenProcessesUpdatesReq 

type ListenProcessesUpdatesReq struct {
	From                 uint64   `protobuf:"varint,1,opt,name=from,proto3" json:"from,omitempty"`
	Service              string   `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListenProcessesUpdatesReq) Descriptor 

func (*ListenProcessesUpdatesReq) Descriptor() ([]byte, []int)

func (*ListenProcessesUpdatesReq) GetFrom 

func (m *ListenProcessesUpdatesReq) GetFrom() uint64

func (*ListenProcessesUpdatesReq) GetService 

func (m *ListenProcessesUpdatesReq) GetService() string

func (*ListenProcessesUpdatesReq) ProtoMessage 

func (*ListenProcessesUpdatesReq) ProtoMessage()

func (*ListenProcessesUpdatesReq) Reset 

func (m *ListenProcessesUpdatesReq) Reset()

func (*ListenProcessesUpdatesReq) String 

func (m *ListenProcessesUpdatesReq) String() string

func (*ListenProcessesUpdatesReq) XXX_DiscardUnknown 

func (m *ListenProcessesUpdatesReq) XXX_DiscardUnknown()

func (*ListenProcessesUpdatesReq) XXX_Marshal 

func (m *ListenProcessesUpdatesReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListenProcessesUpdatesReq) XXX_Merge 

func (m *ListenProcessesUpdatesReq) XXX_Merge(src proto.Message)

func (*ListenProcessesUpdatesReq) XXX_Size 

func (m *ListenProcessesUpdatesReq) XXX_Size() int

func (*ListenProcessesUpdatesReq) XXX_Unmarshal 

func (m *ListenProcessesUpdatesReq) XXX_Unmarshal(b []byte) error

type LockProcessReq 

type LockProcessReq struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LockProcessReq) Descriptor 

func (*LockProcessReq) Descriptor() ([]byte, []int)

func (*LockProcessReq) GetId 

func (m *LockProcessReq) GetId() string

func (*LockProcessReq) ProtoMessage 

func (*LockProcessReq) ProtoMessage()

func (*LockProcessReq) Reset 

func (m *LockProcessReq) Reset()

func (*LockProcessReq) String 

func (m *LockProcessReq) String() string

func (*LockProcessReq) XXX_DiscardUnknown 

func (m *LockProcessReq) XXX_DiscardUnknown()

func (*LockProcessReq) XXX_Marshal 

func (m *LockProcessReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LockProcessReq) XXX_Merge 

func (m *LockProcessReq) XXX_Merge(src proto.Message)

func (*LockProcessReq) XXX_Size 

func (m *LockProcessReq) XXX_Size() int

func (*LockProcessReq) XXX_Unmarshal 

func (m *LockProcessReq) XXX_Unmarshal(b []byte) error

type LockedProcess 

type LockedProcess struct {
	Process              *Process `protobuf:"bytes,1,opt,name=process,proto3" json:"process,omitempty"`
	Thread               *Thread  `protobuf:"bytes,2,opt,name=thread,proto3" json:"thread,omitempty"`
	LockId               uint64   `protobuf:"varint,3,opt,name=lockId,proto3" json:"lockId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LockedProcess) Descriptor 

func (*LockedProcess) Descriptor() ([]byte, []int)

func (*LockedProcess) GetLockId 

func (m *LockedProcess) GetLockId() uint64

func (*LockedProcess) GetProcess 

func (m *LockedProcess) GetProcess() *Process

func (*LockedProcess) GetThread 

func (m *LockedProcess) GetThread() *Thread

func (*LockedProcess) ProtoMessage 

func (*LockedProcess) ProtoMessage()

func (*LockedProcess) Reset 

func (m *LockedProcess) Reset()

func (*LockedProcess) String 

func (m *LockedProcess) String() string

func (*LockedProcess) XXX_DiscardUnknown 

func (m *LockedProcess) XXX_DiscardUnknown()

func (*LockedProcess) XXX_Marshal 

func (m *LockedProcess) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LockedProcess) XXX_Merge 

func (m *LockedProcess) XXX_Merge(src proto.Message)

func (*LockedProcess) XXX_Size 

func (m *LockedProcess) XXX_Size() int

func (*LockedProcess) XXX_Unmarshal 

func (m *LockedProcess) XXX_Unmarshal(b []byte) error

type MakeChanReq 

type MakeChanReq struct {
	Chan                 *Channel `protobuf:"bytes,1,opt,name=chan,proto3" json:"chan,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MakeChanReq) Descriptor 

func (*MakeChanReq) Descriptor() ([]byte, []int)

func (*MakeChanReq) GetChan 

func (m *MakeChanReq) GetChan() *Channel

func (*MakeChanReq) ProtoMessage 

func (*MakeChanReq) ProtoMessage()

func (*MakeChanReq) Reset 

func (m *MakeChanReq) Reset()

func (*MakeChanReq) String 

func (m *MakeChanReq) String() string

func (*MakeChanReq) XXX_DiscardUnknown 

func (m *MakeChanReq) XXX_DiscardUnknown()

func (*MakeChanReq) XXX_Marshal 

func (m *MakeChanReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MakeChanReq) XXX_Merge 

func (m *MakeChanReq) XXX_Merge(src proto.Message)

func (*MakeChanReq) XXX_Size 

func (m *MakeChanReq) XXX_Size() int

func (*MakeChanReq) XXX_Unmarshal 

func (m *MakeChanReq) XXX_Unmarshal(b []byte) error

type NewProcessReq 

type NewProcessReq struct {
	Call                 *Call    `protobuf:"bytes,1,opt,name=call,proto3" json:"call,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Create new process using template

func (*NewProcessReq) Descriptor 

func (*NewProcessReq) Descriptor() ([]byte, []int)

func (*NewProcessReq) GetCall 

func (m *NewProcessReq) GetCall() *Call

func (*NewProcessReq) ProtoMessage 

func (*NewProcessReq) ProtoMessage()

func (*NewProcessReq) Reset 

func (m *NewProcessReq) Reset()

func (*NewProcessReq) String 

func (m *NewProcessReq) String() string

func (*NewProcessReq) XXX_DiscardUnknown 

func (m *NewProcessReq) XXX_DiscardUnknown()

func (*NewProcessReq) XXX_Marshal 

func (m *NewProcessReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NewProcessReq) XXX_Merge 

func (m *NewProcessReq) XXX_Merge(src proto.Message)

func (*NewProcessReq) XXX_Size 

func (m *NewProcessReq) XXX_Size() int

func (*NewProcessReq) XXX_Unmarshal 

func (m *NewProcessReq) XXX_Unmarshal(b []byte) error

type P 

type P struct {
	// contains filtered or unexported fields
}

func (*P) After 

func (p *P) After(after time.Duration) *P

func (*P) At 

func (p *P) At(at time.Time) *P

func (*P) Call 

func (p *P) Call(name string, input interface{}) *P

func (*P) Default 

func (p *P) Default() *P

func (*P) Finish 

func (p *P) Finish(result interface{}) *P

func (*P) Go 

func (p *P) Go(id string, f func(p *P))

func (*P) ID 

func (p *P) ID() string

func (*P) MakeChan 

func (p *P) MakeChan(t *Type, bufsize int) Channel

func (*P) Name 

func (p *P) Name() string

Name is a process name (not ID).

func (*P) NewID 

func (p *P) NewID() string

func (*P) Recv 

func (p *P) Recv(channel Channel) *P

func (*P) Send 

func (p *P) Send(channel Channel, data interface{}) *P

func (*P) Service 

func (p *P) Service() string

Name is a process name (not ID).

func (*P) To 

func (p *P) To(cb interface{}) *P

type Process 

type Process struct {
	Id                   string         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string         `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Service              string         `protobuf:"bytes,3,opt,name=service,proto3" json:"service,omitempty"`
	Status               Process_Status `protobuf:"varint,4,opt,name=status,proto3,enum=async.Process_Status" json:"status,omitempty"`
	Threads              []*Thread      `protobuf:"bytes,5,rep,name=threads,proto3" json:"threads,omitempty"`
	State                []byte         `protobuf:"bytes,6,opt,name=state,proto3" json:"state,omitempty"`
	Input                []byte         `protobuf:"bytes,7,opt,name=input,proto3" json:"input,omitempty"`
	Output               []byte         `protobuf:"bytes,8,opt,name=output,proto3" json:"output,omitempty"`
	Version              uint64         `protobuf:"varint,9,opt,name=version,proto3" json:"version,omitempty"`
	UpdatedAt            uint64         `protobuf:"varint,10,opt,name=updatedAt,proto3" json:"updatedAt,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*Process) Descriptor 

func (*Process) Descriptor() ([]byte, []int)

func (*Process) GetId 

func (m *Process) GetId() string

func (*Process) GetInput 

func (m *Process) GetInput() []byte

func (*Process) GetName 

func (m *Process) GetName() string

func (*Process) GetOutput 

func (m *Process) GetOutput() []byte

func (*Process) GetService 

func (m *Process) GetService() string

func (*Process) GetState 

func (m *Process) GetState() []byte

func (*Process) GetStatus 

func (m *Process) GetStatus() Process_Status

func (*Process) GetThreads 

func (m *Process) GetThreads() []*Thread

func (*Process) GetUpdatedAt 

func (m *Process) GetUpdatedAt() uint64

func (*Process) GetVersion 

func (m *Process) GetVersion() uint64

func (*Process) HasThread 

func (s *Process) HasThread(id string) bool

func (*Process) ProtoMessage 

func (*Process) ProtoMessage()

func (*Process) Reset 

func (m *Process) Reset()

func (*Process) SetThread 

func (s *Process) SetThread(new *Thread) (created bool)

func (*Process) String 

func (m *Process) String() string

func (*Process) XXX_DiscardUnknown 

func (m *Process) XXX_DiscardUnknown()

func (*Process) XXX_Marshal 

func (m *Process) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Process) XXX_Merge 

func (m *Process) XXX_Merge(src proto.Message)

func (*Process) XXX_Size 

func (m *Process) XXX_Size() int

func (*Process) XXX_Unmarshal 

func (m *Process) XXX_Unmarshal(b []byte) error

type ProcessAPI 

type ProcessAPI struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description          string   `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Service              string   `protobuf:"bytes,3,opt,name=service,proto3" json:"service,omitempty"`
	Input                string   `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	Output               string   `protobuf:"bytes,5,opt,name=output,proto3" json:"output,omitempty"`
	State                string   `protobuf:"bytes,6,opt,name=state,proto3" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProcessAPI) Descriptor 

func (*ProcessAPI) Descriptor() ([]byte, []int)

func (*ProcessAPI) GetDescription 

func (m *ProcessAPI) GetDescription() string

func (*ProcessAPI) GetInput 

func (m *ProcessAPI) GetInput() string

func (*ProcessAPI) GetName 

func (m *ProcessAPI) GetName() string

func (*ProcessAPI) GetOutput 

func (m *ProcessAPI) GetOutput() string

func (*ProcessAPI) GetService 

func (m *ProcessAPI) GetService() string

func (*ProcessAPI) GetState 

func (m *ProcessAPI) GetState() string

func (*ProcessAPI) ProtoMessage 

func (*ProcessAPI) ProtoMessage()

func (*ProcessAPI) Reset 

func (m *ProcessAPI) Reset()

func (*ProcessAPI) String 

func (m *ProcessAPI) String() string

func (*ProcessAPI) XXX_DiscardUnknown 

func (m *ProcessAPI) XXX_DiscardUnknown()

func (*ProcessAPI) XXX_Marshal 

func (m *ProcessAPI) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProcessAPI) XXX_Merge 

func (m *ProcessAPI) XXX_Merge(src proto.Message)

func (*ProcessAPI) XXX_Size 

func (m *ProcessAPI) XXX_Size() int

func (*ProcessAPI) XXX_Unmarshal 

func (m *ProcessAPI) XXX_Unmarshal(b []byte) error

type ProcessEvent 

type ProcessEvent struct {
	Process              *Process `protobuf:"bytes,1,opt,name=process,proto3" json:"process,omitempty"`
	Thread               *Thread  `protobuf:"bytes,2,opt,name=thread,proto3" json:"thread,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProcessEvent) Descriptor 

func (*ProcessEvent) Descriptor() ([]byte, []int)

func (*ProcessEvent) GetProcess 

func (m *ProcessEvent) GetProcess() *Process

func (*ProcessEvent) GetThread 

func (m *ProcessEvent) GetThread() *Thread

func (*ProcessEvent) ProtoMessage 

func (*ProcessEvent) ProtoMessage()

func (*ProcessEvent) Reset 

func (m *ProcessEvent) Reset()

func (*ProcessEvent) String 

func (m *ProcessEvent) String() string

func (*ProcessEvent) XXX_DiscardUnknown 

func (m *ProcessEvent) XXX_DiscardUnknown()

func (*ProcessEvent) XXX_Marshal 

func (m *ProcessEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProcessEvent) XXX_Merge 

func (m *ProcessEvent) XXX_Merge(src proto.Message)

func (*ProcessEvent) XXX_Size 

func (m *ProcessEvent) XXX_Size() int

func (*ProcessEvent) XXX_Unmarshal 

func (m *ProcessEvent) XXX_Unmarshal(b []byte) error

type Process_Status 

type Process_Status int32
const (
	Process_Invalid  Process_Status = 0
	Process_Started  Process_Status = 1
	Process_Running  Process_Status = 2
	Process_Finished Process_Status = 3
)

func (Process_Status) EnumDescriptor 

func (Process_Status) EnumDescriptor() ([]byte, []int)

func (Process_Status) String 

func (x Process_Status) String() string

type PutProcessReq 

type PutProcessReq struct {
	Process              *Process `protobuf:"bytes,1,opt,name=process,proto3" json:"process,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Create new process directly

func (*PutProcessReq) Descriptor 

func (*PutProcessReq) Descriptor() ([]byte, []int)

func (*PutProcessReq) GetProcess 

func (m *PutProcessReq) GetProcess() *Process

func (*PutProcessReq) ProtoMessage 

func (*PutProcessReq) ProtoMessage()

func (*PutProcessReq) Reset 

func (m *PutProcessReq) Reset()

func (*PutProcessReq) String 

func (m *PutProcessReq) String() string

func (*PutProcessReq) XXX_DiscardUnknown 

func (m *PutProcessReq) XXX_DiscardUnknown()

func (*PutProcessReq) XXX_Marshal 

func (m *PutProcessReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PutProcessReq) XXX_Merge 

func (m *PutProcessReq) XXX_Merge(src proto.Message)

func (*PutProcessReq) XXX_Size 

func (m *PutProcessReq) XXX_Size() int

func (*PutProcessReq) XXX_Unmarshal 

func (m *PutProcessReq) XXX_Unmarshal(b []byte) error

type RegisterProcessHandlerReq 

type RegisterProcessHandlerReq struct {
	Service              string   `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Pool                 int64    `protobuf:"varint,2,opt,name=pool,proto3" json:"pool,omitempty"`
	PollIntervalMs       int64    `protobuf:"varint,3,opt,name=pollIntervalMs,proto3" json:"pollIntervalMs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegisterProcessHandlerReq) Descriptor 

func (*RegisterProcessHandlerReq) Descriptor() ([]byte, []int)

func (*RegisterProcessHandlerReq) GetPollIntervalMs 

func (m *RegisterProcessHandlerReq) GetPollIntervalMs() int64

func (*RegisterProcessHandlerReq) GetPool 

func (m *RegisterProcessHandlerReq) GetPool() int64

func (*RegisterProcessHandlerReq) GetService 

func (m *RegisterProcessHandlerReq) GetService() string

func (*RegisterProcessHandlerReq) ProtoMessage 

func (*RegisterProcessHandlerReq) ProtoMessage()

func (*RegisterProcessHandlerReq) Reset 

func (m *RegisterProcessHandlerReq) Reset()

func (*RegisterProcessHandlerReq) String 

func (m *RegisterProcessHandlerReq) String() string

func (*RegisterProcessHandlerReq) XXX_DiscardUnknown 

func (m *RegisterProcessHandlerReq) XXX_DiscardUnknown()

func (*RegisterProcessHandlerReq) XXX_Marshal 

func (m *RegisterProcessHandlerReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterProcessHandlerReq) XXX_Merge 

func (m *RegisterProcessHandlerReq) XXX_Merge(src proto.Message)

func (*RegisterProcessHandlerReq) XXX_Size 

func (m *RegisterProcessHandlerReq) XXX_Size() int

func (*RegisterProcessHandlerReq) XXX_Unmarshal 

func (m *RegisterProcessHandlerReq) XXX_Unmarshal(b []byte) error

type RuntimeClient 

type RuntimeClient interface {
	// Get current process
	GetProcess(ctx context.Context, in *GetProcessReq, opts ...grpc.CallOption) (*Process, error)
	NewProcess(ctx context.Context, in *NewProcessReq, opts ...grpc.CallOption) (*Empty, error)
	PutProcess(ctx context.Context, in *PutProcessReq, opts ...grpc.CallOption) (*Empty, error)
	UpdateProcess(ctx context.Context, in *UpdateProcessReq, opts ...grpc.CallOption) (*Empty, error)
	LockProcess(ctx context.Context, in *LockProcessReq, opts ...grpc.CallOption) (*LockedProcess, error)
	MakeChan(ctx context.Context, in *MakeChanReq, opts ...grpc.CallOption) (*Empty, error)
	ListChans(ctx context.Context, in *ListChansReq, opts ...grpc.CallOption) (*ListChansResp, error)
	CloseChan(ctx context.Context, in *CloseChanReq, opts ...grpc.CallOption) (*Empty, error)
	PutType(ctx context.Context, in *Type, opts ...grpc.CallOption) (*Empty, error)
	ListTypes(ctx context.Context, in *ListTypesReq, opts ...grpc.CallOption) (*ListTypesResp, error)
	PutAPI(ctx context.Context, in *ProcessAPI, opts ...grpc.CallOption) (*Empty, error)
	ListAPIs(ctx context.Context, in *ListAPIsReq, opts ...grpc.CallOption) (*ListAPIsResp, error)
	// Listen for unblocked states, process events and return updated states.
	RegisterProcessHandler(ctx context.Context, in *RegisterProcessHandlerReq, opts ...grpc.CallOption) (Runtime_RegisterProcessHandlerClient, error)
	// Listen for updates states. You can use this to sync data with other DB's, for ex. Search / Reports / etc.
	ListenProcessesUpdates(ctx context.Context, in *ListenProcessesUpdatesReq, opts ...grpc.CallOption) (Runtime_ListenProcessesUpdatesClient, error)
}

RuntimeClient is the client API for Runtime service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewRuntimeClient 

func NewRuntimeClient(cc *grpc.ClientConn) RuntimeClient

type RuntimeServer 

type RuntimeServer interface {
	// Get current process
	GetProcess(context.Context, *GetProcessReq) (*Process, error)
	NewProcess(context.Context, *NewProcessReq) (*Empty, error)
	PutProcess(context.Context, *PutProcessReq) (*Empty, error)
	UpdateProcess(context.Context, *UpdateProcessReq) (*Empty, error)
	LockProcess(context.Context, *LockProcessReq) (*LockedProcess, error)
	MakeChan(context.Context, *MakeChanReq) (*Empty, error)
	ListChans(context.Context, *ListChansReq) (*ListChansResp, error)
	CloseChan(context.Context, *CloseChanReq) (*Empty, error)
	PutType(context.Context, *Type) (*Empty, error)
	ListTypes(context.Context, *ListTypesReq) (*ListTypesResp, error)
	PutAPI(context.Context, *ProcessAPI) (*Empty, error)
	ListAPIs(context.Context, *ListAPIsReq) (*ListAPIsResp, error)
	// Listen for unblocked states, process events and return updated states.
	RegisterProcessHandler(*RegisterProcessHandlerReq, Runtime_RegisterProcessHandlerServer) error
	// Listen for updates states. You can use this to sync data with other DB's, for ex. Search / Reports / etc.
	ListenProcessesUpdates(*ListenProcessesUpdatesReq, Runtime_ListenProcessesUpdatesServer) error
}

RuntimeServer is the server API for Runtime service.

type Runtime_ListenProcessesUpdatesClient 

type Runtime_ListenProcessesUpdatesClient interface {
	Recv() (*ProcessEvent, error)
	grpc.ClientStream
}

type Runtime_ListenProcessesUpdatesServer 

type Runtime_ListenProcessesUpdatesServer interface {
	Send(*ProcessEvent) error
	grpc.ServerStream
}

type Runtime_RegisterProcessHandlerClient 

type Runtime_RegisterProcessHandlerClient interface {
	Recv() (*LockedProcess, error)
	grpc.ClientStream
}

type Runtime_RegisterProcessHandlerServer 

type Runtime_RegisterProcessHandlerServer interface {
	Send(*LockedProcess) error
	grpc.ServerStream
}

type Select 

type Select struct {
	Cases []*Case `protobuf:"bytes,1,rep,name=cases,proto3" json:"cases,omitempty"`
	// filled after unblocked
	UnblockedCase        uint64        `protobuf:"varint,2,opt,name=unblockedCase,proto3" json:"unblockedCase,omitempty"`
	RecvData             []byte        `protobuf:"bytes,3,opt,name=recvData,proto3" json:"recvData,omitempty"`
	Result               Select_Result `protobuf:"varint,4,opt,name=result,proto3,enum=async.Select_Result" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*Select) Descriptor 

func (*Select) Descriptor() ([]byte, []int)

func (*Select) GetCases 

func (m *Select) GetCases() []*Case

func (*Select) GetRecvData 

func (m *Select) GetRecvData() []byte

func (*Select) GetResult 

func (m *Select) GetResult() Select_Result

func (*Select) GetUnblockedCase 

func (m *Select) GetUnblockedCase() uint64

func (*Select) ProtoMessage 

func (*Select) ProtoMessage()

func (*Select) Reset 

func (m *Select) Reset()

func (*Select) String 

func (m *Select) String() string

func (*Select) XXX_DiscardUnknown 

func (m *Select) XXX_DiscardUnknown()

func (*Select) XXX_Marshal 

func (m *Select) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Select) XXX_Merge 

func (m *Select) XXX_Merge(src proto.Message)

func (*Select) XXX_Size 

func (m *Select) XXX_Size() int

func (*Select) XXX_Unmarshal 

func (m *Select) XXX_Unmarshal(b []byte) error

type Select_Result 

type Select_Result int32
const (
	Select_Invalid Select_Result = 0
	Select_OK      Select_Result = 1
	Select_Closed  Select_Result = 2
)

func (Select_Result) EnumDescriptor 

func (Select_Result) EnumDescriptor() ([]byte, []int)

func (Select_Result) String 

func (x Select_Result) String() string

type Service 

type Service struct {
	Name         string
	Types        []*Type
	APIs         []API
	Init         func(ctx context.Context) error
	SingletonRun func(ctx context.Context, c RuntimeClient) error
}

type Thread 

type Thread struct {
	Id          string        `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Process     string        `protobuf:"bytes,2,opt,name=process,proto3" json:"process,omitempty"`
	Service     string        `protobuf:"bytes,4,opt,name=service,proto3" json:"service,omitempty"`
	Status      Thread_Status `protobuf:"varint,6,opt,name=status,proto3,enum=async.Thread_Status" json:"status,omitempty"`
	Select      *Select       `protobuf:"bytes,5,opt,name=select,proto3" json:"select,omitempty"`
	Call        *Call         `protobuf:"bytes,12,opt,name=call,proto3" json:"call,omitempty"`
	BlockedAt   uint64        `protobuf:"varint,8,opt,name=blockedAt,proto3" json:"blockedAt,omitempty"`
	UnblockedAt uint64        `protobuf:"varint,9,opt,name=unblockedAt,proto3" json:"unblockedAt,omitempty"`
	// filled after unblocked
	ToStatus             string   `protobuf:"bytes,13,opt,name=toStatus,proto3" json:"toStatus,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Thread) Descriptor 

func (*Thread) Descriptor() ([]byte, []int)

func (*Thread) GetBlockedAt 

func (m *Thread) GetBlockedAt() uint64

func (*Thread) GetCall 

func (m *Thread) GetCall() *Call

func (*Thread) GetId 

func (m *Thread) GetId() string

func (*Thread) GetProcess 

func (m *Thread) GetProcess() string

func (*Thread) GetSelect 

func (m *Thread) GetSelect() *Select

func (*Thread) GetService 

func (m *Thread) GetService() string

func (*Thread) GetStatus 

func (m *Thread) GetStatus() Thread_Status

func (*Thread) GetToStatus 

func (m *Thread) GetToStatus() string

func (*Thread) GetUnblockedAt 

func (m *Thread) GetUnblockedAt() uint64

func (*Thread) ProtoMessage 

func (*Thread) ProtoMessage()

func (*Thread) Reset 

func (m *Thread) Reset()

func (*Thread) String 

func (m *Thread) String() string

func (*Thread) XXX_DiscardUnknown 

func (m *Thread) XXX_DiscardUnknown()

func (*Thread) XXX_Marshal 

func (m *Thread) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Thread) XXX_Merge 

func (m *Thread) XXX_Merge(src proto.Message)

func (*Thread) XXX_Size 

func (m *Thread) XXX_Size() int

func (*Thread) XXX_Unmarshal 

func (m *Thread) XXX_Unmarshal(b []byte) error

type Thread_Status 

type Thread_Status int32
const (
	Thread_Invalid   Thread_Status = 0
	Thread_Blocked   Thread_Status = 1
	Thread_Unblocked Thread_Status = 2
	Thread_Aborted   Thread_Status = 3
)

func (Thread_Status) EnumDescriptor 

func (Thread_Status) EnumDescriptor() ([]byte, []int)

func (Thread_Status) String 

func (x Thread_Status) String() string

type Time 

type Time struct {
	time.Time
}

func (Time) MarshalJSON 

func (t Time) MarshalJSON() ([]byte, error)

func (*Time) UnmarshalJSON 

func (t *Time) UnmarshalJSON(data []byte) error

type Type 

type Type struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Description          string   `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	JsonSchema           []byte   `protobuf:"bytes,3,opt,name=jsonSchema,proto3" json:"jsonSchema,omitempty"`
	Version              uint64   `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func ReflectType 

func ReflectType(name string, t interface{}) *Type

func (*Type) Descriptor 

func (*Type) Descriptor() ([]byte, []int)

func (*Type) GetDescription 

func (m *Type) GetDescription() string

func (*Type) GetId 

func (m *Type) GetId() string

func (*Type) GetJsonSchema 

func (m *Type) GetJsonSchema() []byte

func (*Type) GetVersion 

func (m *Type) GetVersion() uint64

func (*Type) ProtoMessage 

func (*Type) ProtoMessage()

func (*Type) Reset 

func (m *Type) Reset()

func (*Type) String 

func (m *Type) String() string

func (*Type) XXX_DiscardUnknown 

func (m *Type) XXX_DiscardUnknown()

func (*Type) XXX_Marshal 

func (m *Type) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Type) XXX_Merge 

func (m *Type) XXX_Merge(src proto.Message)

func (*Type) XXX_Size 

func (m *Type) XXX_Size() int

func (*Type) XXX_Unmarshal 

func (m *Type) XXX_Unmarshal(b []byte) error

type UpdateProcessReq 

type UpdateProcessReq struct {
	Process              *Process `protobuf:"bytes,1,opt,name=process,proto3" json:"process,omitempty"`
	LockId               uint64   `protobuf:"varint,2,opt,name=lockId,proto3" json:"lockId,omitempty"`
	UnblockedAt          uint64   `protobuf:"varint,3,opt,name=unblockedAt,proto3" json:"unblockedAt,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Update existing process

func (*UpdateProcessReq) Descriptor 

func (*UpdateProcessReq) Descriptor() ([]byte, []int)

func (*UpdateProcessReq) GetLockId 

func (m *UpdateProcessReq) GetLockId() uint64

func (*UpdateProcessReq) GetProcess 

func (m *UpdateProcessReq) GetProcess() *Process

func (*UpdateProcessReq) GetUnblockedAt 

func (m *UpdateProcessReq) GetUnblockedAt() uint64

func (*UpdateProcessReq) ProtoMessage 

func (*UpdateProcessReq) ProtoMessage()

func (*UpdateProcessReq) Reset 

func (m *UpdateProcessReq) Reset()

func (*UpdateProcessReq) String 

func (m *UpdateProcessReq) String() string

func (*UpdateProcessReq) XXX_DiscardUnknown 

func (m *UpdateProcessReq) XXX_DiscardUnknown()

func (*UpdateProcessReq) XXX_Marshal 

func (m *UpdateProcessReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateProcessReq) XXX_Merge 

func (m *UpdateProcessReq) XXX_Merge(src proto.Message)

func (*UpdateProcessReq) XXX_Size 

func (m *UpdateProcessReq) XXX_Size() int

func (*UpdateProcessReq) XXX_Unmarshal 

func (m *UpdateProcessReq) XXX_Unmarshal(b []byte) error

type WaitCallIndex 

type WaitCallIndex struct {
	BlockedAt            uint64   `protobuf:"varint,1,opt,name=blockedAt,proto3" json:"blockedAt,omitempty"`
	ProcessesId          string   `protobuf:"bytes,2,opt,name=processesId,proto3" json:"processesId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WaitCallIndex) Descriptor 

func (*WaitCallIndex) Descriptor() ([]byte, []int)

func (*WaitCallIndex) GetBlockedAt 

func (m *WaitCallIndex) GetBlockedAt() uint64

func (*WaitCallIndex) GetProcessesId 

func (m *WaitCallIndex) GetProcessesId() string

func (*WaitCallIndex) ProtoMessage 

func (*WaitCallIndex) ProtoMessage()

func (*WaitCallIndex) Reset 

func (m *WaitCallIndex) Reset()

func (*WaitCallIndex) String 

func (m *WaitCallIndex) String() string

func (*WaitCallIndex) XXX_DiscardUnknown 

func (m *WaitCallIndex) XXX_DiscardUnknown()

func (*WaitCallIndex) XXX_Marshal 

func (m *WaitCallIndex) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WaitCallIndex) XXX_Merge 

func (m *WaitCallIndex) XXX_Merge(src proto.Message)

func (*WaitCallIndex) XXX_Size 

func (m *WaitCallIndex) XXX_Size() int

func (*WaitCallIndex) XXX_Unmarshal 

func (m *WaitCallIndex) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.