antha_runner_v1

package
v0.0.0-...-040724e Latest Latest
Warning

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

Go to latest
Published: Jun 6, 2019 License: BSD-3-Clause, GPL-2.0 Imports: 6 Imported by: 1

Documentation

Overview

Package antha_runner_v1 is a generated protocol buffer package.

It is generated from these files:

github.com/antha-lang/antha/driver/antha_runner_v1/runner.proto

It has these top-level messages:

RunRequest
RunRefRequest
RunReply
MessagesRequest
MessagesReply
SupportedRunTypesRequest
SupportedRunTypesReply

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterRunnerServer

func RegisterRunnerServer(s *grpc.Server, srv RunnerServer)

Types

type MessagesReply

type MessagesReply struct {
	Values []*MessagesReply_Message `protobuf:"bytes,1,rep,name=values" json:"values,omitempty"`
}

func (*MessagesReply) Descriptor

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

func (*MessagesReply) GetValues

func (m *MessagesReply) GetValues() []*MessagesReply_Message

func (*MessagesReply) ProtoMessage

func (*MessagesReply) ProtoMessage()

func (*MessagesReply) Reset

func (m *MessagesReply) Reset()

func (*MessagesReply) String

func (m *MessagesReply) String() string

type MessagesReply_Message

type MessagesReply_Message struct {
	Code string `protobuf:"bytes,1,opt,name=code" json:"code,omitempty"`
	Seq  int32  `protobuf:"varint,2,opt,name=seq" json:"seq,omitempty"`
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
}

func (*MessagesReply_Message) Descriptor

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

func (*MessagesReply_Message) GetCode

func (m *MessagesReply_Message) GetCode() string

func (*MessagesReply_Message) GetData

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

func (*MessagesReply_Message) GetSeq

func (m *MessagesReply_Message) GetSeq() int32

func (*MessagesReply_Message) ProtoMessage

func (*MessagesReply_Message) ProtoMessage()

func (*MessagesReply_Message) Reset

func (m *MessagesReply_Message) Reset()

func (*MessagesReply_Message) String

func (m *MessagesReply_Message) String() string

type MessagesRequest

type MessagesRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
}

func (*MessagesRequest) Descriptor

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

func (*MessagesRequest) GetId

func (m *MessagesRequest) GetId() string

func (*MessagesRequest) ProtoMessage

func (*MessagesRequest) ProtoMessage()

func (*MessagesRequest) Reset

func (m *MessagesRequest) Reset()

func (*MessagesRequest) String

func (m *MessagesRequest) String() string

type RunRefRequest

type RunRefRequest struct {
	Type string                    `protobuf:"bytes,1,opt,name=type" json:"type,omitempty"`
	Data *antha_driver_v1.HttpCall `protobuf:"bytes,2,opt,name=data" json:"data,omitempty"`
	Done *antha_driver_v1.HttpCall `protobuf:"bytes,3,opt,name=done" json:"done,omitempty"`
}

func (*RunRefRequest) Descriptor

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

func (*RunRefRequest) GetData

func (m *RunRefRequest) GetData() *antha_driver_v1.HttpCall

func (*RunRefRequest) GetDone

func (m *RunRefRequest) GetDone() *antha_driver_v1.HttpCall

func (*RunRefRequest) GetType

func (m *RunRefRequest) GetType() string

func (*RunRefRequest) ProtoMessage

func (*RunRefRequest) ProtoMessage()

func (*RunRefRequest) Reset

func (m *RunRefRequest) Reset()

func (*RunRefRequest) String

func (m *RunRefRequest) String() string

type RunReply

type RunReply struct {
	Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
}

func (*RunReply) Descriptor

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

func (*RunReply) GetId

func (m *RunReply) GetId() string

func (*RunReply) ProtoMessage

func (*RunReply) ProtoMessage()

func (*RunReply) Reset

func (m *RunReply) Reset()

func (*RunReply) String

func (m *RunReply) String() string

type RunRequest

type RunRequest struct {
	Type string                    `protobuf:"bytes,1,opt,name=type" json:"type,omitempty"`
	Data []byte                    `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Done *antha_driver_v1.HttpCall `protobuf:"bytes,3,opt,name=done" json:"done,omitempty"`
}

func (*RunRequest) Descriptor

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

func (*RunRequest) GetData

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

func (*RunRequest) GetDone

func (m *RunRequest) GetDone() *antha_driver_v1.HttpCall

func (*RunRequest) GetType

func (m *RunRequest) GetType() string

func (*RunRequest) ProtoMessage

func (*RunRequest) ProtoMessage()

func (*RunRequest) Reset

func (m *RunRequest) Reset()

func (*RunRequest) String

func (m *RunRequest) String() string

type RunnerClient

type RunnerClient interface {
	// Run a blob
	Run(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (*RunReply, error)
	// Run a blob identified by reference
	RunRef(ctx context.Context, in *RunRefRequest, opts ...grpc.CallOption) (*RunReply, error)
	// Messages from run (call repeatedly to get more messages)
	Messages(ctx context.Context, in *MessagesRequest, opts ...grpc.CallOption) (*MessagesReply, error)
	// Types of files that can be run
	SupportedRunTypes(ctx context.Context, in *SupportedRunTypesRequest, opts ...grpc.CallOption) (*SupportedRunTypesReply, error)
}

func NewRunnerClient

func NewRunnerClient(cc *grpc.ClientConn) RunnerClient

type RunnerServer

type RunnerServer interface {
	// Run a blob
	Run(context.Context, *RunRequest) (*RunReply, error)
	// Run a blob identified by reference
	RunRef(context.Context, *RunRefRequest) (*RunReply, error)
	// Messages from run (call repeatedly to get more messages)
	Messages(context.Context, *MessagesRequest) (*MessagesReply, error)
	// Types of files that can be run
	SupportedRunTypes(context.Context, *SupportedRunTypesRequest) (*SupportedRunTypesReply, error)
}

type SupportedRunTypesReply

type SupportedRunTypesReply struct {
	Types []string `protobuf:"bytes,1,rep,name=types" json:"types,omitempty"`
}

func (*SupportedRunTypesReply) Descriptor

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

func (*SupportedRunTypesReply) GetTypes

func (m *SupportedRunTypesReply) GetTypes() []string

func (*SupportedRunTypesReply) ProtoMessage

func (*SupportedRunTypesReply) ProtoMessage()

func (*SupportedRunTypesReply) Reset

func (m *SupportedRunTypesReply) Reset()

func (*SupportedRunTypesReply) String

func (m *SupportedRunTypesReply) String() string

type SupportedRunTypesRequest

type SupportedRunTypesRequest struct {
}

func (*SupportedRunTypesRequest) Descriptor

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

func (*SupportedRunTypesRequest) ProtoMessage

func (*SupportedRunTypesRequest) ProtoMessage()

func (*SupportedRunTypesRequest) Reset

func (m *SupportedRunTypesRequest) Reset()

func (*SupportedRunTypesRequest) String

func (m *SupportedRunTypesRequest) String() string

Jump to

Keyboard shortcuts

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