grpc_anemos_v1alpha1

package
v0.0.0-...-7d1b802 Latest Latest
Warning

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

Go to latest
Published: Aug 24, 2017 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Package grpc_anemos_v1alpha1 is a generated protocol buffer package.

It is generated from these files:

grpc/anemos/v1alpha1/anemos.proto

It has these top-level messages:

TaskInstance
Event
TriggerRequest
TriggerResponse
ObserverCommandStreamRequest
ObserverCommand
ExecutorCommandStreamRequest
ExecutorCommand

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterExecutorServer

func RegisterExecutorServer(s *grpc.Server, srv ExecutorServer)

func RegisterObserverServer

func RegisterObserverServer(s *grpc.Server, srv ObserverServer)

Types

type Event

type Event struct {
	Uri      string            `protobuf:"bytes,1,opt,name=uri" json:"uri,omitempty"`
	Metadata map[string]string `` /* 136-byte string literal not displayed */
}

func (*Event) Descriptor

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

func (*Event) GetMetadata

func (m *Event) GetMetadata() map[string]string

func (*Event) GetUri

func (m *Event) GetUri() string

func (*Event) ProtoMessage

func (*Event) ProtoMessage()

func (*Event) Reset

func (m *Event) Reset()

func (*Event) String

func (m *Event) String() string

type ExecutorClient

type ExecutorClient interface {
	CommandStream(ctx context.Context, in *ExecutorCommandStreamRequest, opts ...grpc.CallOption) (Executor_CommandStreamClient, error)
}

func NewExecutorClient

func NewExecutorClient(cc *grpc.ClientConn) ExecutorClient

type ExecutorCommand

type ExecutorCommand struct {
	Instance *TaskInstance `protobuf:"bytes,1,opt,name=instance" json:"instance,omitempty"`
}

func (*ExecutorCommand) Descriptor

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

func (*ExecutorCommand) GetInstance

func (m *ExecutorCommand) GetInstance() *TaskInstance

func (*ExecutorCommand) ProtoMessage

func (*ExecutorCommand) ProtoMessage()

func (*ExecutorCommand) Reset

func (m *ExecutorCommand) Reset()

func (*ExecutorCommand) String

func (m *ExecutorCommand) String() string

type ExecutorCommandStreamRequest

type ExecutorCommandStreamRequest struct {
}

func (*ExecutorCommandStreamRequest) Descriptor

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

func (*ExecutorCommandStreamRequest) ProtoMessage

func (*ExecutorCommandStreamRequest) ProtoMessage()

func (*ExecutorCommandStreamRequest) Reset

func (m *ExecutorCommandStreamRequest) Reset()

func (*ExecutorCommandStreamRequest) String

type ExecutorServer

type ExecutorServer interface {
	CommandStream(*ExecutorCommandStreamRequest, Executor_CommandStreamServer) error
}

type Executor_CommandStreamClient

type Executor_CommandStreamClient interface {
	Recv() (*ExecutorCommand, error)
	grpc.ClientStream
}

type Executor_CommandStreamServer

type Executor_CommandStreamServer interface {
	Send(*ExecutorCommand) error
	grpc.ServerStream
}

type ObserverClient

type ObserverClient interface {
	CommandStream(ctx context.Context, in *ObserverCommandStreamRequest, opts ...grpc.CallOption) (Observer_CommandStreamClient, error)
	Trigger(ctx context.Context, in *TriggerRequest, opts ...grpc.CallOption) (*TriggerResponse, error)
}

func NewObserverClient

func NewObserverClient(cc *grpc.ClientConn) ObserverClient

type ObserverCommand

type ObserverCommand struct {
}

func (*ObserverCommand) Descriptor

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

func (*ObserverCommand) ProtoMessage

func (*ObserverCommand) ProtoMessage()

func (*ObserverCommand) Reset

func (m *ObserverCommand) Reset()

func (*ObserverCommand) String

func (m *ObserverCommand) String() string

type ObserverCommandStreamRequest

type ObserverCommandStreamRequest struct {
}

func (*ObserverCommandStreamRequest) Descriptor

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

func (*ObserverCommandStreamRequest) ProtoMessage

func (*ObserverCommandStreamRequest) ProtoMessage()

func (*ObserverCommandStreamRequest) Reset

func (m *ObserverCommandStreamRequest) Reset()

func (*ObserverCommandStreamRequest) String

type Observer_CommandStreamClient

type Observer_CommandStreamClient interface {
	Recv() (*ObserverCommand, error)
	grpc.ClientStream
}

type Observer_CommandStreamServer

type Observer_CommandStreamServer interface {
	Send(*ObserverCommand) error
	grpc.ServerStream
}

type TaskInstance

type TaskInstance struct {
	Provider   string            `protobuf:"bytes,1,opt,name=provider" json:"provider,omitempty"`
	Operation  string            `protobuf:"bytes,2,opt,name=operation" json:"operation,omitempty"`
	Name       string            `protobuf:"bytes,3,opt,name=name" json:"name,omitempty"`
	Id         string            `protobuf:"bytes,4,opt,name=id" json:"id,omitempty"`
	Attributes map[string]string `` /* 140-byte string literal not displayed */
	Metadata   map[string]string `` /* 136-byte string literal not displayed */
}

func (*TaskInstance) Descriptor

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

func (*TaskInstance) GetAttributes

func (m *TaskInstance) GetAttributes() map[string]string

func (*TaskInstance) GetId

func (m *TaskInstance) GetId() string

func (*TaskInstance) GetMetadata

func (m *TaskInstance) GetMetadata() map[string]string

func (*TaskInstance) GetName

func (m *TaskInstance) GetName() string

func (*TaskInstance) GetOperation

func (m *TaskInstance) GetOperation() string

func (*TaskInstance) GetProvider

func (m *TaskInstance) GetProvider() string

func (*TaskInstance) ProtoMessage

func (*TaskInstance) ProtoMessage()

func (*TaskInstance) Reset

func (m *TaskInstance) Reset()

func (*TaskInstance) String

func (m *TaskInstance) String() string

type TriggerRequest

type TriggerRequest struct {
	Event *Event `protobuf:"bytes,1,opt,name=event" json:"event,omitempty"`
}

func (*TriggerRequest) Descriptor

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

func (*TriggerRequest) GetEvent

func (m *TriggerRequest) GetEvent() *Event

func (*TriggerRequest) ProtoMessage

func (*TriggerRequest) ProtoMessage()

func (*TriggerRequest) Reset

func (m *TriggerRequest) Reset()

func (*TriggerRequest) String

func (m *TriggerRequest) String() string

type TriggerResponse

type TriggerResponse struct {
}

func (*TriggerResponse) Descriptor

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

func (*TriggerResponse) ProtoMessage

func (*TriggerResponse) ProtoMessage()

func (*TriggerResponse) Reset

func (m *TriggerResponse) Reset()

func (*TriggerResponse) String

func (m *TriggerResponse) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL