log_v1

type Connections struct {
	ID   string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Path string `protobuf:"bytes,2,opt,name=Path,proto3" json:"Path,omitempty"`
	// contains filtered or unexported fields
}

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

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

type ErrorOffsetOutOfRange struct {
	Offset uint64
}

type GetServersRequest 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 Item struct {
	ID       string        `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Path     string        `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Level    Item_Level    `protobuf:"varint,3,opt,name=level,proto3,enum=log.v1.Item_Level" json:"level,omitempty"`
	Type     Item_Resource `protobuf:"varint,4,opt,name=type,proto3,enum=log.v1.Item_Resource" json:"type,omitempty"`
	Key      string        `protobuf:"bytes,5,opt,name=key,proto3" json:"key,omitempty"`
	Value    string        `protobuf:"bytes,6,opt,name=value,proto3" json:"value,omitempty"`
	Created  int64         `protobuf:"varint,7,opt,name=created,proto3" json:"created,omitempty"`
	Modified int64         `protobuf:"varint,8,opt,name=modified,proto3" json:"modified,omitempty"`
	Version  uint64        `protobuf:"varint,9,opt,name=version,proto3" json:"version,omitempty"`
	Meta     []byte        `protobuf:"bytes,10,opt,name=meta,proto3" json:"meta,omitempty"`
	UserMeta []byte        `protobuf:"bytes,11,opt,name=user_meta,json=userMeta,proto3" json:"user_meta,omitempty"`
	// contains filtered or unexported fields
}

type ItemList struct {
	Items []*Item `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

type Item_Level int32

type Item_Resource int32

type LogClient interface {
	//Unary call
	Produce(ctx context.Context, in *ProduceRequest, opts ...grpc.CallOption) (*ProduceResponse, error)
	//Unary call
	Consume(ctx context.Context, in *ConsumeRequest, opts ...grpc.CallOption) (*ConsumeResponse, error)
	// Streaming server
	ConsumeStream(ctx context.Context, in *ConsumeRequest, opts ...grpc.CallOption) (Log_ConsumeStreamClient, error)
	// Streaming bidirectional
	ProduceStream(ctx context.Context, opts ...grpc.CallOption) (Log_ProduceStreamClient, error)
	// Unary call
	GetServers(ctx context.Context, in *GetServersRequest, opts ...grpc.CallOption) (*GetServersResponse, error)
}

type LogServer interface {
	//Unary call
	Produce(context.Context, *ProduceRequest) (*ProduceResponse, error)
	//Unary call
	Consume(context.Context, *ConsumeRequest) (*ConsumeResponse, error)
	// Streaming server
	ConsumeStream(*ConsumeRequest, Log_ConsumeStreamServer) error
	// Streaming bidirectional
	ProduceStream(Log_ProduceStreamServer) error
	// Unary call
	GetServers(context.Context, *GetServersRequest) (*GetServersResponse, error)
	// contains filtered or unexported methods
}

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

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

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

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

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

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

type Record struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `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 UnimplementedLogServer struct {
}

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