mako_internal_quickstore_microservice

package
v0.0.0-...-62801f1 Latest Latest
Warning

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

Go to latest
Published: Jan 22, 2020 License: Apache-2.0, Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterQuickstoreServer

func RegisterQuickstoreServer(s *grpc.Server, srv QuickstoreServer)

Types

type QuickstoreClient

type QuickstoreClient interface {
	Store(ctx context.Context, in *StoreInput, opts ...grpc.CallOption) (*StoreOutput, error)
	ShutdownMicroservice(ctx context.Context, in *ShutdownInput, opts ...grpc.CallOption) (*ShutdownOutput, error)
}

QuickstoreClient is the client API for Quickstore service.

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

func NewQuickstoreClient

func NewQuickstoreClient(cc *grpc.ClientConn) QuickstoreClient

type QuickstoreServer

type QuickstoreServer interface {
	Store(context.Context, *StoreInput) (*StoreOutput, error)
	ShutdownMicroservice(context.Context, *ShutdownInput) (*ShutdownOutput, error)
}

QuickstoreServer is the server API for Quickstore service.

type ShutdownInput

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

func (*ShutdownInput) Descriptor

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

func (*ShutdownInput) ProtoMessage

func (*ShutdownInput) ProtoMessage()

func (*ShutdownInput) Reset

func (m *ShutdownInput) Reset()

func (*ShutdownInput) String

func (m *ShutdownInput) String() string

func (*ShutdownInput) XXX_DiscardUnknown

func (m *ShutdownInput) XXX_DiscardUnknown()

func (*ShutdownInput) XXX_Marshal

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

func (*ShutdownInput) XXX_Merge

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

func (*ShutdownInput) XXX_Size

func (m *ShutdownInput) XXX_Size() int

func (*ShutdownInput) XXX_Unmarshal

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

type ShutdownOutput

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

func (*ShutdownOutput) Descriptor

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

func (*ShutdownOutput) ProtoMessage

func (*ShutdownOutput) ProtoMessage()

func (*ShutdownOutput) Reset

func (m *ShutdownOutput) Reset()

func (*ShutdownOutput) String

func (m *ShutdownOutput) String() string

func (*ShutdownOutput) XXX_DiscardUnknown

func (m *ShutdownOutput) XXX_DiscardUnknown()

func (*ShutdownOutput) XXX_Marshal

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

func (*ShutdownOutput) XXX_Merge

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

func (*ShutdownOutput) XXX_Size

func (m *ShutdownOutput) XXX_Size() int

func (*ShutdownOutput) XXX_Unmarshal

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

type StoreInput

type StoreInput struct {
	QuickstoreInput      *quickstore_go_proto.QuickstoreInput `protobuf:"bytes,1,opt,name=quickstore_input,json=quickstoreInput" json:"quickstore_input,omitempty"`
	SamplePoints         []*mako_go_proto.SamplePoint         `protobuf:"bytes,2,rep,name=sample_points,json=samplePoints" json:"sample_points,omitempty"`
	SampleErrors         []*mako_go_proto.SampleError         `protobuf:"bytes,3,rep,name=sample_errors,json=sampleErrors" json:"sample_errors,omitempty"`
	RunAggregates        []*mako_go_proto.KeyedValue          `protobuf:"bytes,4,rep,name=run_aggregates,json=runAggregates" json:"run_aggregates,omitempty"`
	AggregateValueKeys   []string                             `protobuf:"bytes,5,rep,name=aggregate_value_keys,json=aggregateValueKeys" json:"aggregate_value_keys,omitempty"`
	AggregateValueTypes  []string                             `protobuf:"bytes,6,rep,name=aggregate_value_types,json=aggregateValueTypes" json:"aggregate_value_types,omitempty"`
	AggregateValueValues []float64                            `protobuf:"fixed64,7,rep,name=aggregate_value_values,json=aggregateValueValues" json:"aggregate_value_values,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                             `json:"-"`
	XXX_unrecognized     []byte                               `json:"-"`
	XXX_sizecache        int32                                `json:"-"`
}

func (*StoreInput) Descriptor

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

func (*StoreInput) GetAggregateValueKeys

func (m *StoreInput) GetAggregateValueKeys() []string

func (*StoreInput) GetAggregateValueTypes

func (m *StoreInput) GetAggregateValueTypes() []string

func (*StoreInput) GetAggregateValueValues

func (m *StoreInput) GetAggregateValueValues() []float64

func (*StoreInput) GetQuickstoreInput

func (m *StoreInput) GetQuickstoreInput() *quickstore_go_proto.QuickstoreInput

func (*StoreInput) GetRunAggregates

func (m *StoreInput) GetRunAggregates() []*mako_go_proto.KeyedValue

func (*StoreInput) GetSampleErrors

func (m *StoreInput) GetSampleErrors() []*mako_go_proto.SampleError

func (*StoreInput) GetSamplePoints

func (m *StoreInput) GetSamplePoints() []*mako_go_proto.SamplePoint

func (*StoreInput) ProtoMessage

func (*StoreInput) ProtoMessage()

func (*StoreInput) Reset

func (m *StoreInput) Reset()

func (*StoreInput) String

func (m *StoreInput) String() string

func (*StoreInput) XXX_DiscardUnknown

func (m *StoreInput) XXX_DiscardUnknown()

func (*StoreInput) XXX_Marshal

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

func (*StoreInput) XXX_Merge

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

func (*StoreInput) XXX_Size

func (m *StoreInput) XXX_Size() int

func (*StoreInput) XXX_Unmarshal

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

type StoreOutput

type StoreOutput struct {
	QuickstoreOutput     *quickstore_go_proto.QuickstoreOutput `protobuf:"bytes,1,opt,name=quickstore_output,json=quickstoreOutput" json:"quickstore_output,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                              `json:"-"`
	XXX_unrecognized     []byte                                `json:"-"`
	XXX_sizecache        int32                                 `json:"-"`
}

func (*StoreOutput) Descriptor

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

func (*StoreOutput) GetQuickstoreOutput

func (m *StoreOutput) GetQuickstoreOutput() *quickstore_go_proto.QuickstoreOutput

func (*StoreOutput) ProtoMessage

func (*StoreOutput) ProtoMessage()

func (*StoreOutput) Reset

func (m *StoreOutput) Reset()

func (*StoreOutput) String

func (m *StoreOutput) String() string

func (*StoreOutput) XXX_DiscardUnknown

func (m *StoreOutput) XXX_DiscardUnknown()

func (*StoreOutput) XXX_Marshal

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

func (*StoreOutput) XXX_Merge

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

func (*StoreOutput) XXX_Size

func (m *StoreOutput) XXX_Size() int

func (*StoreOutput) XXX_Unmarshal

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

Jump to

Keyboard shortcuts

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