store_v1

type Action struct {
	Type       Action_Type `protobuf:"varint,1,opt,name=type,proto3,enum=store.v1.Action_Type" json:"type,omitempty"`
	Submessage []byte      `protobuf:"bytes,2,opt,name=submessage,proto3" json:"submessage,omitempty"`
	// contains filtered or unexported fields
}

type Action_Type int32

type ConsumeRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

type ConsumeResponse struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type ConsumeResponseRecord struct {
	Record *Record `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

type ErrKeyNotFound struct {
	Key []byte
}

type GetServerRequest struct {
	// contains filtered or unexported fields
}

type GetServersResponse struct {
	Servers []*Server `protobuf:"bytes,1,rep,name=servers,proto3" json:"servers,omitempty"`
	// contains filtered or unexported fields
}

type MultipleConsume struct {
	Pairs []*Record `protobuf:"bytes,1,rep,name=pairs,proto3" json:"pairs,omitempty"`
	// contains filtered or unexported fields
}

type Prefix struct {
	Prefix []byte `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// contains filtered or unexported fields
}

type ProduceRequest struct {
	Record *Record `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

type ProduceResponse struct {
	// contains filtered or unexported fields
}

type Record struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type Server struct {
	Id       string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	RpcAddr  string `protobuf:"bytes,2,opt,name=rpc_addr,json=rpcAddr,proto3" json:"rpc_addr,omitempty"`
	IsLeader bool   `protobuf:"varint,3,opt,name=is_leader,json=isLeader,proto3" json:"is_leader,omitempty"`
	// contains filtered or unexported fields
}

type StoreClient interface {
	Produce(ctx context.Context, in *ProduceRequest, opts ...grpc.CallOption) (*ProduceResponse, error)
	Consume(ctx context.Context, in *ConsumeRequest, opts ...grpc.CallOption) (*ConsumeResponse, error)
	ConsumeWithKey(ctx context.Context, in *ConsumeRequest, opts ...grpc.CallOption) (*ConsumeResponseRecord, error)
	ProduceStream(ctx context.Context, opts ...grpc.CallOption) (Store_ProduceStreamClient, error)
	AllKeysAndValues(ctx context.Context, in *StoreEmptyRequest, opts ...grpc.CallOption) (*MultipleConsume, error)
	PrefixConsume(ctx context.Context, in *Prefix, opts ...grpc.CallOption) (*MultipleConsume, error)
	// This is really bad XD
	ConsumeStream(ctx context.Context, in *StoreEmptyRequest, opts ...grpc.CallOption) (Store_ConsumeStreamClient, error)
	ConsumeStreamWithKey(ctx context.Context, in *StoreEmptyRequest, opts ...grpc.CallOption) (Store_ConsumeStreamWithKeyClient, error)
	GetServers(ctx context.Context, in *GetServerRequest, opts ...grpc.CallOption) (*GetServersResponse, error)
}

type StoreEmptyRequest struct {
	// contains filtered or unexported fields
}

type StoreServer interface {
	Produce(context.Context, *ProduceRequest) (*ProduceResponse, error)
	Consume(context.Context, *ConsumeRequest) (*ConsumeResponse, error)
	ConsumeWithKey(context.Context, *ConsumeRequest) (*ConsumeResponseRecord, error)
	ProduceStream(Store_ProduceStreamServer) error
	AllKeysAndValues(context.Context, *StoreEmptyRequest) (*MultipleConsume, error)
	PrefixConsume(context.Context, *Prefix) (*MultipleConsume, error)
	// This is really bad XD
	ConsumeStream(*StoreEmptyRequest, Store_ConsumeStreamServer) error
	ConsumeStreamWithKey(*StoreEmptyRequest, Store_ConsumeStreamWithKeyServer) error
	GetServers(context.Context, *GetServerRequest) (*GetServersResponse, error)
	// contains filtered or unexported methods
}

type Store_ConsumeStreamClient interface {
	Recv() (*ConsumeResponse, error)
	grpc.ClientStream
}

type Store_ConsumeStreamServer interface {
	Send(*ConsumeResponse) error
	grpc.ServerStream
}

type Store_ConsumeStreamWithKeyClient interface {
	Recv() (*ConsumeResponseRecord, error)
	grpc.ClientStream
}

type Store_ConsumeStreamWithKeyServer interface {
	Send(*ConsumeResponseRecord) error
	grpc.ServerStream
}

type Store_ProduceStreamClient interface {
	Send(*ProduceRequest) error
	Recv() (*ProduceResponse, error)
	grpc.ClientStream
}

type Store_ProduceStreamServer interface {
	Send(*ProduceResponse) error
	Recv() (*ProduceRequest, error)
	grpc.ServerStream
}

type UnimplementedStoreServer struct {
}

type UnsafeStoreServer interface {
	// contains filtered or unexported methods
}