mako_internal_quickstore_microservice

package
v0.0.0-...-75da391 Latest Latest
Warning

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

 Go to latest Published: Sep 5, 2019 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

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.