input

Documentation

Index

• func RegisterRecorderServer(s *grpc.Server, srv RecorderServer)
• type Input
  • func (*Input) Descriptor() ([]byte, []int)
  • func (m *Input) GetFirst() string
  • func (m *Input) GetLast() string
  • func (*Input) ProtoMessage()
  • func (m *Input) Reset()
  • func (m *Input) String() string
  • func (m *Input) XXX_DiscardUnknown()
  • func (m *Input) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Input) XXX_Merge(src proto.Message)
  • func (m *Input) XXX_Size() int
  • func (m *Input) XXX_Unmarshal(b []byte) error
• type Output
  • func (*Output) Descriptor() ([]byte, []int)
  • func (m *Output) GetId() uint64
  • func (m *Output) GetPayload() []byte
  • func (*Output) ProtoMessage()
  • func (m *Output) Reset()
  • func (m *Output) String() string
  • func (m *Output) XXX_DiscardUnknown()
  • func (m *Output) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Output) XXX_Merge(src proto.Message)
  • func (m *Output) XXX_Size() int
  • func (m *Output) XXX_Unmarshal(b []byte) error
• type RecorderClient
  • func NewRecorderClient(cc *grpc.ClientConn) RecorderClient
• type RecorderServer

Functions

func RegisterRecorderServer

func RegisterRecorderServer(s *grpc.Server, srv RecorderServer)

Types

type Input

type Input struct {
	First                string   `protobuf:"bytes,1,opt,name=first,proto3" json:"first,omitempty"`
	Last                 string   `protobuf:"bytes,2,opt,name=last,proto3" json:"last,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Input is the standard name for a Cog's input.

func (*Input) Descriptor

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

func (*Input) GetFirst

func (m *Input) GetFirst() string

func (*Input) GetLast

func (m *Input) GetLast() 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 Output

type Output struct {
	Id                   uint64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Payload              []byte   `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Output is the standard name for a Cog's output.

func (*Output) Descriptor

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

func (*Output) GetId

func (m *Output) GetId() uint64

func (*Output) GetPayload

func (m *Output) GetPayload() []byte

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 RecorderClient

type RecorderClient interface {
	Record(ctx context.Context, in *Input, opts ...grpc.CallOption) (*Output, error)
}

RecorderClient is the client API for Recorder service.

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

func NewRecorderClient

func NewRecorderClient(cc *grpc.ClientConn) RecorderClient

type RecorderServer

type RecorderServer interface {
	Record(context.Context, *Input) (*Output, error)
}

RecorderServer is the server API for Recorder service.