watchv1

package
v1.0.1 Latest Latest
Warning

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

 Go to latest Published: Aug 9, 2021 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterWatchAPIServer 

func RegisterWatchAPIServer(s *grpc.Server, srv WatchAPIServer)

Types

type Action 

type Action struct {
	// Types that are valid to be assigned to Action:
	//	*Action_ActionJoin
	//	*Action_ActionLookup
	//	*Action_ActionGetState
	//	*Action_ActionSetState
	//	*Action_ActionOutput
	Action               isAction_Action `protobuf_oneof:"action"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

Action is a streaming action a processor takes during an operation.

func (*Action) Descriptor 

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

func (*Action) GetAction 

func (m *Action) GetAction() isAction_Action

func (*Action) GetActionGetState 

func (m *Action) GetActionGetState() *GetState

func (*Action) GetActionJoin 

func (m *Action) GetActionJoin() *Join

func (*Action) GetActionLookup 

func (m *Action) GetActionLookup() *Lookup

func (*Action) GetActionOutput 

func (m *Action) GetActionOutput() *Output

func (*Action) GetActionSetState 

func (m *Action) GetActionSetState() *SetState

func (*Action) ProtoMessage 

func (*Action) ProtoMessage()

func (*Action) Reset 

func (m *Action) Reset()

func (*Action) String 

func (m *Action) String() string

func (*Action) XXX_DiscardUnknown 

func (m *Action) XXX_DiscardUnknown()

func (*Action) XXX_Marshal 

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

func (*Action) XXX_Merge 

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

func (*Action) XXX_OneofWrappers 

func (*Action) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Action) XXX_Size 

func (m *Action) XXX_Size() int

func (*Action) XXX_Unmarshal 

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

type Action_ActionGetState 

type Action_ActionGetState struct {
	ActionGetState *GetState `protobuf:"bytes,3,opt,name=action_get_state,json=actionGetState,proto3,oneof"`
}

type Action_ActionJoin 

type Action_ActionJoin struct {
	ActionJoin *Join `protobuf:"bytes,1,opt,name=action_join,json=actionJoin,proto3,oneof"`
}

type Action_ActionLookup 

type Action_ActionLookup struct {
	ActionLookup *Lookup `protobuf:"bytes,2,opt,name=action_lookup,json=actionLookup,proto3,oneof"`
}

type Action_ActionOutput 

type Action_ActionOutput struct {
	ActionOutput *Output `protobuf:"bytes,5,opt,name=action_output,json=actionOutput,proto3,oneof"`
}

type Action_ActionSetState 

type Action_ActionSetState struct {
	ActionSetState *SetState `protobuf:"bytes,4,opt,name=action_set_state,json=actionSetState,proto3,oneof"`
}

type GetState 

type GetState struct {
	Topic                string   `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Value                string   `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetState is a persistence action.

func (*GetState) Descriptor 

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

func (*GetState) GetMessage 

func (m *GetState) GetMessage() string

func (*GetState) GetTopic 

func (m *GetState) GetTopic() string

func (*GetState) GetValue 

func (m *GetState) GetValue() string

func (*GetState) ProtoMessage 

func (*GetState) ProtoMessage()

func (*GetState) Reset 

func (m *GetState) Reset()

func (*GetState) String 

func (m *GetState) String() string

func (*GetState) XXX_DiscardUnknown 

func (m *GetState) XXX_DiscardUnknown()

func (*GetState) XXX_Marshal 

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

func (*GetState) XXX_Merge 

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

func (*GetState) XXX_Size 

func (m *GetState) XXX_Size() int

func (*GetState) XXX_Unmarshal 

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

type Input 

type Input struct {
	Topic                string   `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Value                string   `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Input is the input message that triggered the processor.

func (*Input) Descriptor 

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

func (*Input) GetMessage 

func (m *Input) GetMessage() string

func (*Input) GetTopic 

func (m *Input) GetTopic() string

func (*Input) GetValue 

func (m *Input) GetValue() string

func (*Input) ProtoMessage 

func (*Input) ProtoMessage()

func (*Input) Reset 

func (m *Input) Reset()

func (*Input) String 

func (m *Input) String() string

func (*Input) XXX_DiscardUnknown 

func (m *Input) XXX_DiscardUnknown()

func (*Input) XXX_Marshal 

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

func (*Input) XXX_Merge 

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

func (*Input) XXX_Size 

func (m *Input) XXX_Size() int

func (*Input) XXX_Unmarshal 

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

type Join 

type Join struct {
	Topic                string   `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Value                string   `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Join is a join action.

func (*Join) Descriptor 

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

func (*Join) GetMessage 

func (m *Join) GetMessage() string

func (*Join) GetTopic 

func (m *Join) GetTopic() string

func (*Join) GetValue 

func (m *Join) GetValue() string

func (*Join) ProtoMessage 

func (*Join) ProtoMessage()

func (*Join) Reset 

func (m *Join) Reset()

func (*Join) String 

func (m *Join) String() string

func (*Join) XXX_DiscardUnknown 

func (m *Join) XXX_DiscardUnknown()

func (*Join) XXX_Marshal 

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

func (*Join) XXX_Merge 

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

func (*Join) XXX_Size 

func (m *Join) XXX_Size() int

func (*Join) XXX_Unmarshal 

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

type Lookup 

type Lookup struct {
	Topic                string   `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Key                  string   `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Value                string   `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Lookup is a lookup action.

func (*Lookup) Descriptor 

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

func (*Lookup) GetKey 

func (m *Lookup) GetKey() string

func (*Lookup) GetMessage 

func (m *Lookup) GetMessage() string

func (*Lookup) GetTopic 

func (m *Lookup) GetTopic() string

func (*Lookup) GetValue 

func (m *Lookup) GetValue() string

func (*Lookup) ProtoMessage 

func (*Lookup) ProtoMessage()

func (*Lookup) Reset 

func (m *Lookup) Reset()

func (*Lookup) String 

func (m *Lookup) String() string

func (*Lookup) XXX_DiscardUnknown 

func (m *Lookup) XXX_DiscardUnknown()

func (*Lookup) XXX_Marshal 

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

func (*Lookup) XXX_Merge 

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

func (*Lookup) XXX_Size 

func (m *Lookup) XXX_Size() int

func (*Lookup) XXX_Unmarshal 

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

type Operation 

type Operation struct {
	StartTime            *timestamp.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime              *timestamp.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Input                *Input               `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	Actions              []*Action            `protobuf:"bytes,4,rep,name=actions,proto3" json:"actions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Operation is a processor operation trigged by an input.

func (*Operation) Descriptor 

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

func (*Operation) GetActions 

func (m *Operation) GetActions() []*Action

func (*Operation) GetEndTime 

func (m *Operation) GetEndTime() *timestamp.Timestamp

func (*Operation) GetInput 

func (m *Operation) GetInput() *Input

func (*Operation) GetStartTime 

func (m *Operation) GetStartTime() *timestamp.Timestamp

func (*Operation) ProtoMessage 

func (*Operation) ProtoMessage()

func (*Operation) Reset 

func (m *Operation) Reset()

func (*Operation) String 

func (m *Operation) String() string

func (*Operation) XXX_DiscardUnknown 

func (m *Operation) XXX_DiscardUnknown()

func (*Operation) XXX_Marshal 

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

func (*Operation) XXX_Merge 

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

func (*Operation) XXX_Size 

func (m *Operation) XXX_Size() int

func (*Operation) XXX_Unmarshal 

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

type Output 

type Output struct {
	Topic                string   `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Key                  string   `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Value                string   `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Output is an output action.

func (*Output) Descriptor 

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

func (*Output) GetKey 

func (m *Output) GetKey() string

func (*Output) GetMessage 

func (m *Output) GetMessage() string

func (*Output) GetTopic 

func (m *Output) GetTopic() string

func (*Output) GetValue 

func (m *Output) GetValue() string

func (*Output) ProtoMessage 

func (*Output) ProtoMessage()

func (*Output) Reset 

func (m *Output) Reset()

func (*Output) String 

func (m *Output) String() string

func (*Output) XXX_DiscardUnknown 

func (m *Output) XXX_DiscardUnknown()

func (*Output) XXX_Marshal 

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

func (*Output) XXX_Merge 

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

func (*Output) XXX_Size 

func (m *Output) XXX_Size() int

func (*Output) XXX_Unmarshal 

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

type ProcessorRequest 

type ProcessorRequest struct {
	Component            string   `protobuf:"bytes,1,opt,name=component,proto3" json:"component,omitempty"`
	Processor            string   `protobuf:"bytes,2,opt,name=processor,proto3" json:"processor,omitempty"`
	Key                  string   `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProcessorRequest) Descriptor 

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

func (*ProcessorRequest) GetComponent 

func (m *ProcessorRequest) GetComponent() string

func (*ProcessorRequest) GetKey 

func (m *ProcessorRequest) GetKey() string

func (*ProcessorRequest) GetProcessor 

func (m *ProcessorRequest) GetProcessor() string

func (*ProcessorRequest) ProtoMessage 

func (*ProcessorRequest) ProtoMessage()

func (*ProcessorRequest) Reset 

func (m *ProcessorRequest) Reset()

func (*ProcessorRequest) String 

func (m *ProcessorRequest) String() string

func (*ProcessorRequest) XXX_DiscardUnknown 

func (m *ProcessorRequest) XXX_DiscardUnknown()

func (*ProcessorRequest) XXX_Marshal 

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

func (*ProcessorRequest) XXX_Merge 

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

func (*ProcessorRequest) XXX_Size 

func (m *ProcessorRequest) XXX_Size() int

func (*ProcessorRequest) XXX_Unmarshal 

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

type ProcessorResponse 

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

func (*ProcessorResponse) Descriptor 

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

func (*ProcessorResponse) GetOperation 

func (m *ProcessorResponse) GetOperation() *Operation

func (*ProcessorResponse) ProtoMessage 

func (*ProcessorResponse) ProtoMessage()

func (*ProcessorResponse) Reset 

func (m *ProcessorResponse) Reset()

func (*ProcessorResponse) String 

func (m *ProcessorResponse) String() string

func (*ProcessorResponse) XXX_DiscardUnknown 

func (m *ProcessorResponse) XXX_DiscardUnknown()

func (*ProcessorResponse) XXX_Marshal 

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

func (*ProcessorResponse) XXX_Merge 

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

func (*ProcessorResponse) XXX_Size 

func (m *ProcessorResponse) XXX_Size() int

func (*ProcessorResponse) XXX_Unmarshal 

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

type SetState 

type SetState struct {
	Topic                string   `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Value                string   `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

SetState is a persistence action.

func (*SetState) Descriptor 

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

func (*SetState) GetMessage 

func (m *SetState) GetMessage() string

func (*SetState) GetTopic 

func (m *SetState) GetTopic() string

func (*SetState) GetValue 

func (m *SetState) GetValue() string

func (*SetState) ProtoMessage 

func (*SetState) ProtoMessage()

func (*SetState) Reset 

func (m *SetState) Reset()

func (*SetState) String 

func (m *SetState) String() string

func (*SetState) XXX_DiscardUnknown 

func (m *SetState) XXX_DiscardUnknown()

func (*SetState) XXX_Marshal 

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

func (*SetState) XXX_Merge 

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

func (*SetState) XXX_Size 

func (m *SetState) XXX_Size() int

func (*SetState) XXX_Unmarshal 

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

type WatchAPIClient 

type WatchAPIClient interface {
	// Processor will return operations from a processor based on key.
	Processor(ctx context.Context, in *ProcessorRequest, opts ...grpc.CallOption) (WatchAPI_ProcessorClient, error)
}

WatchAPIClient is the client API for WatchAPI service.

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

func NewWatchAPIClient 

func NewWatchAPIClient(cc *grpc.ClientConn) WatchAPIClient

type WatchAPIServer 

type WatchAPIServer interface {
	// Processor will return operations from a processor based on key.
	Processor(*ProcessorRequest, WatchAPI_ProcessorServer) error
}

WatchAPIServer is the server API for WatchAPI service.

type WatchAPI_ProcessorClient 

type WatchAPI_ProcessorClient interface {
	Recv() (*ProcessorResponse, error)
	grpc.ClientStream
}

type WatchAPI_ProcessorServer 

type WatchAPI_ProcessorServer interface {
	Send(*ProcessorResponse) error
	grpc.ServerStream
}

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.