driver: github.com/streamsdb/driver/go/sdb/internal/api Index | Files

package api

import "github.com/streamsdb/driver/go/sdb/internal/api"

Index

Package Files

api.go

Variables

var Direction_name = map[int32]string{
    0:  "FORWARD",
    1:  "BACKWARD",
}
var Direction_value = map[string]int32{
    "FORWARD":  0,
    "BACKWARD": 1,
}

func RegisterStreamsServer Uses

func RegisterStreamsServer(s *grpc.Server, srv StreamsServer)

type AppendStreamReply Uses

type AppendStreamReply struct {
    From                 int64    `protobuf:"varint,1,opt,name=from,proto3" json:"from,omitempty"`
    Version              int64    `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*AppendStreamReply) Descriptor Uses

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

func (*AppendStreamReply) GetFrom Uses

func (m *AppendStreamReply) GetFrom() int64

func (*AppendStreamReply) GetVersion Uses

func (m *AppendStreamReply) GetVersion() int64

func (*AppendStreamReply) ProtoMessage Uses

func (*AppendStreamReply) ProtoMessage()

func (*AppendStreamReply) Reset Uses

func (m *AppendStreamReply) Reset()

func (*AppendStreamReply) String Uses

func (m *AppendStreamReply) String() string

func (*AppendStreamReply) XXX_DiscardUnknown Uses

func (m *AppendStreamReply) XXX_DiscardUnknown()

func (*AppendStreamReply) XXX_Marshal Uses

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

func (*AppendStreamReply) XXX_Merge Uses

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

func (*AppendStreamReply) XXX_Size Uses

func (m *AppendStreamReply) XXX_Size() int

func (*AppendStreamReply) XXX_Unmarshal Uses

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

type AppendStreamRequest Uses

type AppendStreamRequest struct {
    Database             string          `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
    Stream               string          `protobuf:"bytes,2,opt,name=stream,proto3" json:"stream,omitempty"`
    Messages             []*MessageInput `protobuf:"bytes,3,rep,name=messages,proto3" json:"messages,omitempty"`
    ExpectedVersion      int64           `protobuf:"varint,4,opt,name=expectedVersion,proto3" json:"expectedVersion,omitempty"`
    XXX_NoUnkeyedLiteral struct{}        `json:"-"`
    XXX_unrecognized     []byte          `json:"-"`
    XXX_sizecache        int32           `json:"-"`
}

func (*AppendStreamRequest) Descriptor Uses

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

func (*AppendStreamRequest) GetDatabase Uses

func (m *AppendStreamRequest) GetDatabase() string

func (*AppendStreamRequest) GetExpectedVersion Uses

func (m *AppendStreamRequest) GetExpectedVersion() int64

func (*AppendStreamRequest) GetMessages Uses

func (m *AppendStreamRequest) GetMessages() []*MessageInput

func (*AppendStreamRequest) GetStream Uses

func (m *AppendStreamRequest) GetStream() string

func (*AppendStreamRequest) ProtoMessage Uses

func (*AppendStreamRequest) ProtoMessage()

func (*AppendStreamRequest) Reset Uses

func (m *AppendStreamRequest) Reset()

func (*AppendStreamRequest) String Uses

func (m *AppendStreamRequest) String() string

func (*AppendStreamRequest) XXX_DiscardUnknown Uses

func (m *AppendStreamRequest) XXX_DiscardUnknown()

func (*AppendStreamRequest) XXX_Marshal Uses

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

func (*AppendStreamRequest) XXX_Merge Uses

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

func (*AppendStreamRequest) XXX_Size Uses

func (m *AppendStreamRequest) XXX_Size() int

func (*AppendStreamRequest) XXX_Unmarshal Uses

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

type AppendStreamsReply Uses

type AppendStreamsReply struct {
    Results              []*StreamAppendResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
    XXX_NoUnkeyedLiteral struct{}              `json:"-"`
    XXX_unrecognized     []byte                `json:"-"`
    XXX_sizecache        int32                 `json:"-"`
}

func (*AppendStreamsReply) Descriptor Uses

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

func (*AppendStreamsReply) GetResults Uses

func (m *AppendStreamsReply) GetResults() []*StreamAppendResult

func (*AppendStreamsReply) ProtoMessage Uses

func (*AppendStreamsReply) ProtoMessage()

func (*AppendStreamsReply) Reset Uses

func (m *AppendStreamsReply) Reset()

func (*AppendStreamsReply) String Uses

func (m *AppendStreamsReply) String() string

func (*AppendStreamsReply) XXX_DiscardUnknown Uses

func (m *AppendStreamsReply) XXX_DiscardUnknown()

func (*AppendStreamsReply) XXX_Marshal Uses

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

func (*AppendStreamsReply) XXX_Merge Uses

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

func (*AppendStreamsReply) XXX_Size Uses

func (m *AppendStreamsReply) XXX_Size() int

func (*AppendStreamsReply) XXX_Unmarshal Uses

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

type AppendStreamsRequest Uses

type AppendStreamsRequest struct {
    Database             string         `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
    Inputs               []*StreamInput `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty"`
    XXX_NoUnkeyedLiteral struct{}       `json:"-"`
    XXX_unrecognized     []byte         `json:"-"`
    XXX_sizecache        int32          `json:"-"`
}

func (*AppendStreamsRequest) Descriptor Uses

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

func (*AppendStreamsRequest) GetDatabase Uses

func (m *AppendStreamsRequest) GetDatabase() string

func (*AppendStreamsRequest) GetInputs Uses

func (m *AppendStreamsRequest) GetInputs() []*StreamInput

func (*AppendStreamsRequest) ProtoMessage Uses

func (*AppendStreamsRequest) ProtoMessage()

func (*AppendStreamsRequest) Reset Uses

func (m *AppendStreamsRequest) Reset()

func (*AppendStreamsRequest) String Uses

func (m *AppendStreamsRequest) String() string

func (*AppendStreamsRequest) XXX_DiscardUnknown Uses

func (m *AppendStreamsRequest) XXX_DiscardUnknown()

func (*AppendStreamsRequest) XXX_Marshal Uses

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

func (*AppendStreamsRequest) XXX_Merge Uses

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

func (*AppendStreamsRequest) XXX_Size Uses

func (m *AppendStreamsRequest) XXX_Size() int

func (*AppendStreamsRequest) XXX_Unmarshal Uses

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

type ChangePasswordReply Uses

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

func (*ChangePasswordReply) Descriptor Uses

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

func (*ChangePasswordReply) ProtoMessage Uses

func (*ChangePasswordReply) ProtoMessage()

func (*ChangePasswordReply) Reset Uses

func (m *ChangePasswordReply) Reset()

func (*ChangePasswordReply) String Uses

func (m *ChangePasswordReply) String() string

func (*ChangePasswordReply) XXX_DiscardUnknown Uses

func (m *ChangePasswordReply) XXX_DiscardUnknown()

func (*ChangePasswordReply) XXX_Marshal Uses

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

func (*ChangePasswordReply) XXX_Merge Uses

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

func (*ChangePasswordReply) XXX_Size Uses

func (m *ChangePasswordReply) XXX_Size() int

func (*ChangePasswordReply) XXX_Unmarshal Uses

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

type ChangePasswordRequest Uses

type ChangePasswordRequest struct {
    Username             string   `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
    Password             string   `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*ChangePasswordRequest) Descriptor Uses

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

func (*ChangePasswordRequest) GetPassword Uses

func (m *ChangePasswordRequest) GetPassword() string

func (*ChangePasswordRequest) GetUsername Uses

func (m *ChangePasswordRequest) GetUsername() string

func (*ChangePasswordRequest) ProtoMessage Uses

func (*ChangePasswordRequest) ProtoMessage()

func (*ChangePasswordRequest) Reset Uses

func (m *ChangePasswordRequest) Reset()

func (*ChangePasswordRequest) String Uses

func (m *ChangePasswordRequest) String() string

func (*ChangePasswordRequest) XXX_DiscardUnknown Uses

func (m *ChangePasswordRequest) XXX_DiscardUnknown()

func (*ChangePasswordRequest) XXX_Marshal Uses

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

func (*ChangePasswordRequest) XXX_Merge Uses

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

func (*ChangePasswordRequest) XXX_Size Uses

func (m *ChangePasswordRequest) XXX_Size() int

func (*ChangePasswordRequest) XXX_Unmarshal Uses

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

type CreateDatabaseReply Uses

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

func (*CreateDatabaseReply) Descriptor Uses

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

func (*CreateDatabaseReply) ProtoMessage Uses

func (*CreateDatabaseReply) ProtoMessage()

func (*CreateDatabaseReply) Reset Uses

func (m *CreateDatabaseReply) Reset()

func (*CreateDatabaseReply) String Uses

func (m *CreateDatabaseReply) String() string

func (*CreateDatabaseReply) XXX_DiscardUnknown Uses

func (m *CreateDatabaseReply) XXX_DiscardUnknown()

func (*CreateDatabaseReply) XXX_Marshal Uses

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

func (*CreateDatabaseReply) XXX_Merge Uses

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

func (*CreateDatabaseReply) XXX_Size Uses

func (m *CreateDatabaseReply) XXX_Size() int

func (*CreateDatabaseReply) XXX_Unmarshal Uses

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

type CreateDatabaseRequest Uses

type CreateDatabaseRequest struct {
    Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*CreateDatabaseRequest) Descriptor Uses

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

func (*CreateDatabaseRequest) GetName Uses

func (m *CreateDatabaseRequest) GetName() string

func (*CreateDatabaseRequest) ProtoMessage Uses

func (*CreateDatabaseRequest) ProtoMessage()

func (*CreateDatabaseRequest) Reset Uses

func (m *CreateDatabaseRequest) Reset()

func (*CreateDatabaseRequest) String Uses

func (m *CreateDatabaseRequest) String() string

func (*CreateDatabaseRequest) XXX_DiscardUnknown Uses

func (m *CreateDatabaseRequest) XXX_DiscardUnknown()

func (*CreateDatabaseRequest) XXX_Marshal Uses

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

func (*CreateDatabaseRequest) XXX_Merge Uses

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

func (*CreateDatabaseRequest) XXX_Size Uses

func (m *CreateDatabaseRequest) XXX_Size() int

func (*CreateDatabaseRequest) XXX_Unmarshal Uses

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

type CreateUserReply Uses

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

func (*CreateUserReply) Descriptor Uses

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

func (*CreateUserReply) ProtoMessage Uses

func (*CreateUserReply) ProtoMessage()

func (*CreateUserReply) Reset Uses

func (m *CreateUserReply) Reset()

func (*CreateUserReply) String Uses

func (m *CreateUserReply) String() string

func (*CreateUserReply) XXX_DiscardUnknown Uses

func (m *CreateUserReply) XXX_DiscardUnknown()

func (*CreateUserReply) XXX_Marshal Uses

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

func (*CreateUserReply) XXX_Merge Uses

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

func (*CreateUserReply) XXX_Size Uses

func (m *CreateUserReply) XXX_Size() int

func (*CreateUserReply) XXX_Unmarshal Uses

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

type CreateUserRequest Uses

type CreateUserRequest struct {
    Username             string   `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
    Password             string   `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*CreateUserRequest) Descriptor Uses

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

func (*CreateUserRequest) GetPassword Uses

func (m *CreateUserRequest) GetPassword() string

func (*CreateUserRequest) GetUsername Uses

func (m *CreateUserRequest) GetUsername() string

func (*CreateUserRequest) ProtoMessage Uses

func (*CreateUserRequest) ProtoMessage()

func (*CreateUserRequest) Reset Uses

func (m *CreateUserRequest) Reset()

func (*CreateUserRequest) String Uses

func (m *CreateUserRequest) String() string

func (*CreateUserRequest) XXX_DiscardUnknown Uses

func (m *CreateUserRequest) XXX_DiscardUnknown()

func (*CreateUserRequest) XXX_Marshal Uses

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

func (*CreateUserRequest) XXX_Merge Uses

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

func (*CreateUserRequest) XXX_Size Uses

func (m *CreateUserRequest) XXX_Size() int

func (*CreateUserRequest) XXX_Unmarshal Uses

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

type DeleteMessageReply Uses

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

func (*DeleteMessageReply) Descriptor Uses

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

func (*DeleteMessageReply) ProtoMessage Uses

func (*DeleteMessageReply) ProtoMessage()

func (*DeleteMessageReply) Reset Uses

func (m *DeleteMessageReply) Reset()

func (*DeleteMessageReply) String Uses

func (m *DeleteMessageReply) String() string

func (*DeleteMessageReply) XXX_DiscardUnknown Uses

func (m *DeleteMessageReply) XXX_DiscardUnknown()

func (*DeleteMessageReply) XXX_Marshal Uses

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

func (*DeleteMessageReply) XXX_Merge Uses

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

func (*DeleteMessageReply) XXX_Size Uses

func (m *DeleteMessageReply) XXX_Size() int

func (*DeleteMessageReply) XXX_Unmarshal Uses

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

type DeleteMessageRequest Uses

type DeleteMessageRequest struct {
    Database             string   `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
    Stream               string   `protobuf:"bytes,2,opt,name=stream,proto3" json:"stream,omitempty"`
    Position             int64    `protobuf:"varint,3,opt,name=position,proto3" json:"position,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*DeleteMessageRequest) Descriptor Uses

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

func (*DeleteMessageRequest) GetDatabase Uses

func (m *DeleteMessageRequest) GetDatabase() string

func (*DeleteMessageRequest) GetPosition Uses

func (m *DeleteMessageRequest) GetPosition() int64

func (*DeleteMessageRequest) GetStream Uses

func (m *DeleteMessageRequest) GetStream() string

func (*DeleteMessageRequest) ProtoMessage Uses

func (*DeleteMessageRequest) ProtoMessage()

func (*DeleteMessageRequest) Reset Uses

func (m *DeleteMessageRequest) Reset()

func (*DeleteMessageRequest) String Uses

func (m *DeleteMessageRequest) String() string

func (*DeleteMessageRequest) XXX_DiscardUnknown Uses

func (m *DeleteMessageRequest) XXX_DiscardUnknown()

func (*DeleteMessageRequest) XXX_Marshal Uses

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

func (*DeleteMessageRequest) XXX_Merge Uses

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

func (*DeleteMessageRequest) XXX_Size Uses

func (m *DeleteMessageRequest) XXX_Size() int

func (*DeleteMessageRequest) XXX_Unmarshal Uses

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

type DeleteStreamReply Uses

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

func (*DeleteStreamReply) Descriptor Uses

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

func (*DeleteStreamReply) ProtoMessage Uses

func (*DeleteStreamReply) ProtoMessage()

func (*DeleteStreamReply) Reset Uses

func (m *DeleteStreamReply) Reset()

func (*DeleteStreamReply) String Uses

func (m *DeleteStreamReply) String() string

func (*DeleteStreamReply) XXX_DiscardUnknown Uses

func (m *DeleteStreamReply) XXX_DiscardUnknown()

func (*DeleteStreamReply) XXX_Marshal Uses

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

func (*DeleteStreamReply) XXX_Merge Uses

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

func (*DeleteStreamReply) XXX_Size Uses

func (m *DeleteStreamReply) XXX_Size() int

func (*DeleteStreamReply) XXX_Unmarshal Uses

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

type DeleteStreamRequest Uses

type DeleteStreamRequest struct {
    Database             string   `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
    Stream               string   `protobuf:"bytes,2,opt,name=stream,proto3" json:"stream,omitempty"`
    ExpectedVersion      int64    `protobuf:"varint,3,opt,name=expectedVersion,proto3" json:"expectedVersion,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*DeleteStreamRequest) Descriptor Uses

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

func (*DeleteStreamRequest) GetDatabase Uses

func (m *DeleteStreamRequest) GetDatabase() string

func (*DeleteStreamRequest) GetExpectedVersion Uses

func (m *DeleteStreamRequest) GetExpectedVersion() int64

func (*DeleteStreamRequest) GetStream Uses

func (m *DeleteStreamRequest) GetStream() string

func (*DeleteStreamRequest) ProtoMessage Uses

func (*DeleteStreamRequest) ProtoMessage()

func (*DeleteStreamRequest) Reset Uses

func (m *DeleteStreamRequest) Reset()

func (*DeleteStreamRequest) String Uses

func (m *DeleteStreamRequest) String() string

func (*DeleteStreamRequest) XXX_DiscardUnknown Uses

func (m *DeleteStreamRequest) XXX_DiscardUnknown()

func (*DeleteStreamRequest) XXX_Marshal Uses

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

func (*DeleteStreamRequest) XXX_Merge Uses

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

func (*DeleteStreamRequest) XXX_Size Uses

func (m *DeleteStreamRequest) XXX_Size() int

func (*DeleteStreamRequest) XXX_Unmarshal Uses

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

type Direction Uses

type Direction int32
const (
    Direction_FORWARD  Direction = 0
    Direction_BACKWARD Direction = 1
)

func (Direction) EnumDescriptor Uses

func (Direction) EnumDescriptor() ([]byte, []int)

func (Direction) String Uses

func (x Direction) String() string

type EnableAclReply Uses

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

func (*EnableAclReply) Descriptor Uses

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

func (*EnableAclReply) ProtoMessage Uses

func (*EnableAclReply) ProtoMessage()

func (*EnableAclReply) Reset Uses

func (m *EnableAclReply) Reset()

func (*EnableAclReply) String Uses

func (m *EnableAclReply) String() string

func (*EnableAclReply) XXX_DiscardUnknown Uses

func (m *EnableAclReply) XXX_DiscardUnknown()

func (*EnableAclReply) XXX_Marshal Uses

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

func (*EnableAclReply) XXX_Merge Uses

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

func (*EnableAclReply) XXX_Size Uses

func (m *EnableAclReply) XXX_Size() int

func (*EnableAclReply) XXX_Unmarshal Uses

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

type EnableAclRequest Uses

type EnableAclRequest struct {
    Username             string   `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
    Password             string   `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
    Signature            []byte   `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*EnableAclRequest) Descriptor Uses

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

func (*EnableAclRequest) GetPassword Uses

func (m *EnableAclRequest) GetPassword() string

func (*EnableAclRequest) GetSignature Uses

func (m *EnableAclRequest) GetSignature() []byte

func (*EnableAclRequest) GetUsername Uses

func (m *EnableAclRequest) GetUsername() string

func (*EnableAclRequest) ProtoMessage Uses

func (*EnableAclRequest) ProtoMessage()

func (*EnableAclRequest) Reset Uses

func (m *EnableAclRequest) Reset()

func (*EnableAclRequest) String Uses

func (m *EnableAclRequest) String() string

func (*EnableAclRequest) XXX_DiscardUnknown Uses

func (m *EnableAclRequest) XXX_DiscardUnknown()

func (*EnableAclRequest) XXX_Marshal Uses

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

func (*EnableAclRequest) XXX_Merge Uses

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

func (*EnableAclRequest) XXX_Size Uses

func (m *EnableAclRequest) XXX_Size() int

func (*EnableAclRequest) XXX_Unmarshal Uses

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

type GetDatabaseReply Uses

type GetDatabaseReply struct {
    Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*GetDatabaseReply) Descriptor Uses

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

func (*GetDatabaseReply) GetName Uses

func (m *GetDatabaseReply) GetName() string

func (*GetDatabaseReply) ProtoMessage Uses

func (*GetDatabaseReply) ProtoMessage()

func (*GetDatabaseReply) Reset Uses

func (m *GetDatabaseReply) Reset()

func (*GetDatabaseReply) String Uses

func (m *GetDatabaseReply) String() string

func (*GetDatabaseReply) XXX_DiscardUnknown Uses

func (m *GetDatabaseReply) XXX_DiscardUnknown()

func (*GetDatabaseReply) XXX_Marshal Uses

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

func (*GetDatabaseReply) XXX_Merge Uses

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

func (*GetDatabaseReply) XXX_Size Uses

func (m *GetDatabaseReply) XXX_Size() int

func (*GetDatabaseReply) XXX_Unmarshal Uses

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

type GetDatabaseRequest Uses

type GetDatabaseRequest struct {
    Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*GetDatabaseRequest) Descriptor Uses

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

func (*GetDatabaseRequest) GetName Uses

func (m *GetDatabaseRequest) GetName() string

func (*GetDatabaseRequest) ProtoMessage Uses

func (*GetDatabaseRequest) ProtoMessage()

func (*GetDatabaseRequest) Reset Uses

func (m *GetDatabaseRequest) Reset()

func (*GetDatabaseRequest) String Uses

func (m *GetDatabaseRequest) String() string

func (*GetDatabaseRequest) XXX_DiscardUnknown Uses

func (m *GetDatabaseRequest) XXX_DiscardUnknown()

func (*GetDatabaseRequest) XXX_Marshal Uses

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

func (*GetDatabaseRequest) XXX_Merge Uses

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

func (*GetDatabaseRequest) XXX_Size Uses

func (m *GetDatabaseRequest) XXX_Size() int

func (*GetDatabaseRequest) XXX_Unmarshal Uses

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

type GetDatabasesReply Uses

type GetDatabasesReply struct {
    Databases            []string `protobuf:"bytes,1,rep,name=databases,proto3" json:"databases,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*GetDatabasesReply) Descriptor Uses

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

func (*GetDatabasesReply) GetDatabases Uses

func (m *GetDatabasesReply) GetDatabases() []string

func (*GetDatabasesReply) ProtoMessage Uses

func (*GetDatabasesReply) ProtoMessage()

func (*GetDatabasesReply) Reset Uses

func (m *GetDatabasesReply) Reset()

func (*GetDatabasesReply) String Uses

func (m *GetDatabasesReply) String() string

func (*GetDatabasesReply) XXX_DiscardUnknown Uses

func (m *GetDatabasesReply) XXX_DiscardUnknown()

func (*GetDatabasesReply) XXX_Marshal Uses

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

func (*GetDatabasesReply) XXX_Merge Uses

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

func (*GetDatabasesReply) XXX_Size Uses

func (m *GetDatabasesReply) XXX_Size() int

func (*GetDatabasesReply) XXX_Unmarshal Uses

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

type GetDatabasesRequest Uses

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

func (*GetDatabasesRequest) Descriptor Uses

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

func (*GetDatabasesRequest) ProtoMessage Uses

func (*GetDatabasesRequest) ProtoMessage()

func (*GetDatabasesRequest) Reset Uses

func (m *GetDatabasesRequest) Reset()

func (*GetDatabasesRequest) String Uses

func (m *GetDatabasesRequest) String() string

func (*GetDatabasesRequest) XXX_DiscardUnknown Uses

func (m *GetDatabasesRequest) XXX_DiscardUnknown()

func (*GetDatabasesRequest) XXX_Marshal Uses

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

func (*GetDatabasesRequest) XXX_Merge Uses

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

func (*GetDatabasesRequest) XXX_Size Uses

func (m *GetDatabasesRequest) XXX_Size() int

func (*GetDatabasesRequest) XXX_Unmarshal Uses

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

type GetStreamsReply Uses

type GetStreamsReply struct {
    Total                int64     `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
    Cursor               string    `protobuf:"bytes,2,opt,name=cursor,proto3" json:"cursor,omitempty"`
    Direction            Direction `protobuf:"varint,3,opt,name=direction,proto3,enum=streamsdb.api.Direction" json:"direction,omitempty"`
    HasBefore            bool      `protobuf:"varint,4,opt,name=hasBefore,proto3" json:"hasBefore,omitempty"`
    HasAfter             bool      `protobuf:"varint,5,opt,name=hasAfter,proto3" json:"hasAfter,omitempty"`
    BeforeCursor         string    `protobuf:"bytes,6,opt,name=beforeCursor,proto3" json:"beforeCursor,omitempty"`
    AfterCursor          string    `protobuf:"bytes,7,opt,name=afterCursor,proto3" json:"afterCursor,omitempty"`
    Result               []string  `protobuf:"bytes,8,rep,name=result,proto3" json:"result,omitempty"`
    Filter               string    `protobuf:"bytes,9,opt,name=filter,proto3" json:"filter,omitempty"`
    Limit                int32     `protobuf:"varint,10,opt,name=limit,proto3" json:"limit,omitempty"`
    XXX_NoUnkeyedLiteral struct{}  `json:"-"`
    XXX_unrecognized     []byte    `json:"-"`
    XXX_sizecache        int32     `json:"-"`
}

func (*GetStreamsReply) Descriptor Uses

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

func (*GetStreamsReply) GetAfterCursor Uses

func (m *GetStreamsReply) GetAfterCursor() string

func (*GetStreamsReply) GetBeforeCursor Uses

func (m *GetStreamsReply) GetBeforeCursor() string

func (*GetStreamsReply) GetCursor Uses

func (m *GetStreamsReply) GetCursor() string

func (*GetStreamsReply) GetDirection Uses

func (m *GetStreamsReply) GetDirection() Direction

func (*GetStreamsReply) GetFilter Uses

func (m *GetStreamsReply) GetFilter() string

func (*GetStreamsReply) GetHasAfter Uses

func (m *GetStreamsReply) GetHasAfter() bool

func (*GetStreamsReply) GetHasBefore Uses

func (m *GetStreamsReply) GetHasBefore() bool

func (*GetStreamsReply) GetLimit Uses

func (m *GetStreamsReply) GetLimit() int32

func (*GetStreamsReply) GetResult Uses

func (m *GetStreamsReply) GetResult() []string

func (*GetStreamsReply) GetTotal Uses

func (m *GetStreamsReply) GetTotal() int64

func (*GetStreamsReply) ProtoMessage Uses

func (*GetStreamsReply) ProtoMessage()

func (*GetStreamsReply) Reset Uses

func (m *GetStreamsReply) Reset()

func (*GetStreamsReply) String Uses

func (m *GetStreamsReply) String() string

func (*GetStreamsReply) XXX_DiscardUnknown Uses

func (m *GetStreamsReply) XXX_DiscardUnknown()

func (*GetStreamsReply) XXX_Marshal Uses

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

func (*GetStreamsReply) XXX_Merge Uses

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

func (*GetStreamsReply) XXX_Size Uses

func (m *GetStreamsReply) XXX_Size() int

func (*GetStreamsReply) XXX_Unmarshal Uses

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

type GetStreamsRequest Uses

type GetStreamsRequest struct {
    Database             string    `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
    Cursor               string    `protobuf:"bytes,2,opt,name=cursor,proto3" json:"cursor,omitempty"`
    Direction            Direction `protobuf:"varint,3,opt,name=direction,proto3,enum=streamsdb.api.Direction" json:"direction,omitempty"`
    Filter               string    `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
    Limit                int32     `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"`
    XXX_NoUnkeyedLiteral struct{}  `json:"-"`
    XXX_unrecognized     []byte    `json:"-"`
    XXX_sizecache        int32     `json:"-"`
}

func (*GetStreamsRequest) Descriptor Uses

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

func (*GetStreamsRequest) GetCursor Uses

func (m *GetStreamsRequest) GetCursor() string

func (*GetStreamsRequest) GetDatabase Uses

func (m *GetStreamsRequest) GetDatabase() string

func (*GetStreamsRequest) GetDirection Uses

func (m *GetStreamsRequest) GetDirection() Direction

func (*GetStreamsRequest) GetFilter Uses

func (m *GetStreamsRequest) GetFilter() string

func (*GetStreamsRequest) GetLimit Uses

func (m *GetStreamsRequest) GetLimit() int32

func (*GetStreamsRequest) ProtoMessage Uses

func (*GetStreamsRequest) ProtoMessage()

func (*GetStreamsRequest) Reset Uses

func (m *GetStreamsRequest) Reset()

func (*GetStreamsRequest) String Uses

func (m *GetStreamsRequest) String() string

func (*GetStreamsRequest) XXX_DiscardUnknown Uses

func (m *GetStreamsRequest) XXX_DiscardUnknown()

func (*GetStreamsRequest) XXX_Marshal Uses

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

func (*GetStreamsRequest) XXX_Merge Uses

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

func (*GetStreamsRequest) XXX_Size Uses

func (m *GetStreamsRequest) XXX_Size() int

func (*GetStreamsRequest) XXX_Unmarshal Uses

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

type GrandUserToDatabaseReply Uses

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

func (*GrandUserToDatabaseReply) Descriptor Uses

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

func (*GrandUserToDatabaseReply) ProtoMessage Uses

func (*GrandUserToDatabaseReply) ProtoMessage()

func (*GrandUserToDatabaseReply) Reset Uses

func (m *GrandUserToDatabaseReply) Reset()

func (*GrandUserToDatabaseReply) String Uses

func (m *GrandUserToDatabaseReply) String() string

func (*GrandUserToDatabaseReply) XXX_DiscardUnknown Uses

func (m *GrandUserToDatabaseReply) XXX_DiscardUnknown()

func (*GrandUserToDatabaseReply) XXX_Marshal Uses

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

func (*GrandUserToDatabaseReply) XXX_Merge Uses

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

func (*GrandUserToDatabaseReply) XXX_Size Uses

func (m *GrandUserToDatabaseReply) XXX_Size() int

func (*GrandUserToDatabaseReply) XXX_Unmarshal Uses

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

type GrandUserToDatabaseRequest Uses

type GrandUserToDatabaseRequest struct {
    Username             string   `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
    Database             string   `protobuf:"bytes,2,opt,name=database,proto3" json:"database,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*GrandUserToDatabaseRequest) Descriptor Uses

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

func (*GrandUserToDatabaseRequest) GetDatabase Uses

func (m *GrandUserToDatabaseRequest) GetDatabase() string

func (*GrandUserToDatabaseRequest) GetUsername Uses

func (m *GrandUserToDatabaseRequest) GetUsername() string

func (*GrandUserToDatabaseRequest) ProtoMessage Uses

func (*GrandUserToDatabaseRequest) ProtoMessage()

func (*GrandUserToDatabaseRequest) Reset Uses

func (m *GrandUserToDatabaseRequest) Reset()

func (*GrandUserToDatabaseRequest) String Uses

func (m *GrandUserToDatabaseRequest) String() string

func (*GrandUserToDatabaseRequest) XXX_DiscardUnknown Uses

func (m *GrandUserToDatabaseRequest) XXX_DiscardUnknown()

func (*GrandUserToDatabaseRequest) XXX_Marshal Uses

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

func (*GrandUserToDatabaseRequest) XXX_Merge Uses

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

func (*GrandUserToDatabaseRequest) XXX_Size Uses

func (m *GrandUserToDatabaseRequest) XXX_Size() int

func (*GrandUserToDatabaseRequest) XXX_Unmarshal Uses

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

type LoginReply Uses

type LoginReply struct {
    Token                string   `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*LoginReply) Descriptor Uses

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

func (*LoginReply) GetToken Uses

func (m *LoginReply) GetToken() string

func (*LoginReply) ProtoMessage Uses

func (*LoginReply) ProtoMessage()

func (*LoginReply) Reset Uses

func (m *LoginReply) Reset()

func (*LoginReply) String Uses

func (m *LoginReply) String() string

func (*LoginReply) XXX_DiscardUnknown Uses

func (m *LoginReply) XXX_DiscardUnknown()

func (*LoginReply) XXX_Marshal Uses

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

func (*LoginReply) XXX_Merge Uses

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

func (*LoginReply) XXX_Size Uses

func (m *LoginReply) XXX_Size() int

func (*LoginReply) XXX_Unmarshal Uses

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

type LoginRequest Uses

type LoginRequest struct {
    Username             string   `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
    Password             string   `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*LoginRequest) Descriptor Uses

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

func (*LoginRequest) GetPassword Uses

func (m *LoginRequest) GetPassword() string

func (*LoginRequest) GetUsername Uses

func (m *LoginRequest) GetUsername() string

func (*LoginRequest) ProtoMessage Uses

func (*LoginRequest) ProtoMessage()

func (*LoginRequest) Reset Uses

func (m *LoginRequest) Reset()

func (*LoginRequest) String Uses

func (m *LoginRequest) String() string

func (*LoginRequest) XXX_DiscardUnknown Uses

func (m *LoginRequest) XXX_DiscardUnknown()

func (*LoginRequest) XXX_Marshal Uses

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

func (*LoginRequest) XXX_Merge Uses

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

func (*LoginRequest) XXX_Size Uses

func (m *LoginRequest) XXX_Size() int

func (*LoginRequest) XXX_Unmarshal Uses

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

type Message Uses

type Message struct {
    Id                   string           `protobuf:"bytes,7,opt,name=id,proto3" json:"id,omitempty"`
    Stream               string           `protobuf:"bytes,6,opt,name=stream,proto3" json:"stream,omitempty"`
    Position             int64            `protobuf:"varint,1,opt,name=position,proto3" json:"position,omitempty"`
    Type                 string           `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
    Timestamp            *types.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
    Header               []byte           `protobuf:"bytes,4,opt,name=header,proto3" json:"header,omitempty"`
    Value                []byte           `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"`
    XXX_NoUnkeyedLiteral struct{}         `json:"-"`
    XXX_unrecognized     []byte           `json:"-"`
    XXX_sizecache        int32            `json:"-"`
}

func (*Message) Descriptor Uses

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

func (*Message) GetHeader Uses

func (m *Message) GetHeader() []byte

func (*Message) GetId Uses

func (m *Message) GetId() string

func (*Message) GetPosition Uses

func (m *Message) GetPosition() int64

func (*Message) GetStream Uses

func (m *Message) GetStream() string

func (*Message) GetTimestamp Uses

func (m *Message) GetTimestamp() *types.Timestamp

func (*Message) GetType Uses

func (m *Message) GetType() string

func (*Message) GetValue Uses

func (m *Message) GetValue() []byte

func (*Message) ProtoMessage Uses

func (*Message) ProtoMessage()

func (*Message) Reset Uses

func (m *Message) Reset()

func (*Message) String Uses

func (m *Message) String() string

func (*Message) XXX_DiscardUnknown Uses

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal Uses

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

func (*Message) XXX_Merge Uses

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

func (*Message) XXX_Size Uses

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal Uses

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

type MessageInput Uses

type MessageInput struct {
    Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
    Type                 string   `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
    Header               []byte   `protobuf:"bytes,3,opt,name=header,proto3" json:"header,omitempty"`
    Value                []byte   `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*MessageInput) Descriptor Uses

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

func (*MessageInput) GetHeader Uses

func (m *MessageInput) GetHeader() []byte

func (*MessageInput) GetId Uses

func (m *MessageInput) GetId() string

func (*MessageInput) GetType Uses

func (m *MessageInput) GetType() string

func (*MessageInput) GetValue Uses

func (m *MessageInput) GetValue() []byte

func (*MessageInput) ProtoMessage Uses

func (*MessageInput) ProtoMessage()

func (*MessageInput) Reset Uses

func (m *MessageInput) Reset()

func (*MessageInput) String Uses

func (m *MessageInput) String() string

func (*MessageInput) XXX_DiscardUnknown Uses

func (m *MessageInput) XXX_DiscardUnknown()

func (*MessageInput) XXX_Marshal Uses

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

func (*MessageInput) XXX_Merge Uses

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

func (*MessageInput) XXX_Size Uses

func (m *MessageInput) XXX_Size() int

func (*MessageInput) XXX_Unmarshal Uses

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

type PingReply Uses

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

func (*PingReply) Descriptor Uses

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

func (*PingReply) ProtoMessage Uses

func (*PingReply) ProtoMessage()

func (*PingReply) Reset Uses

func (m *PingReply) Reset()

func (*PingReply) String Uses

func (m *PingReply) String() string

func (*PingReply) XXX_DiscardUnknown Uses

func (m *PingReply) XXX_DiscardUnknown()

func (*PingReply) XXX_Marshal Uses

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

func (*PingReply) XXX_Merge Uses

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

func (*PingReply) XXX_Size Uses

func (m *PingReply) XXX_Size() int

func (*PingReply) XXX_Unmarshal Uses

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

type PingRequest Uses

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

func (*PingRequest) Descriptor Uses

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

func (*PingRequest) ProtoMessage Uses

func (*PingRequest) ProtoMessage()

func (*PingRequest) Reset Uses

func (m *PingRequest) Reset()

func (*PingRequest) String Uses

func (m *PingRequest) String() string

func (*PingRequest) XXX_DiscardUnknown Uses

func (m *PingRequest) XXX_DiscardUnknown()

func (*PingRequest) XXX_Marshal Uses

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

func (*PingRequest) XXX_Merge Uses

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

func (*PingRequest) XXX_Size Uses

func (m *PingRequest) XXX_Size() int

func (*PingRequest) XXX_Unmarshal Uses

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

type ReadGlobalReply Uses

type ReadGlobalReply struct {
    Database             string     `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
    From                 []byte     `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"`
    Next                 []byte     `protobuf:"bytes,3,opt,name=next,proto3" json:"next,omitempty"`
    HasNext              bool       `protobuf:"varint,5,opt,name=hasNext,proto3" json:"hasNext,omitempty"`
    Messages             []*Message `protobuf:"bytes,4,rep,name=messages,proto3" json:"messages,omitempty"`
    XXX_NoUnkeyedLiteral struct{}   `json:"-"`
    XXX_unrecognized     []byte     `json:"-"`
    XXX_sizecache        int32      `json:"-"`
}

func (*ReadGlobalReply) Descriptor Uses

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

func (*ReadGlobalReply) GetDatabase Uses

func (m *ReadGlobalReply) GetDatabase() string

func (*ReadGlobalReply) GetFrom Uses

func (m *ReadGlobalReply) GetFrom() []byte

func (*ReadGlobalReply) GetHasNext Uses

func (m *ReadGlobalReply) GetHasNext() bool

func (*ReadGlobalReply) GetMessages Uses

func (m *ReadGlobalReply) GetMessages() []*Message

func (*ReadGlobalReply) GetNext Uses

func (m *ReadGlobalReply) GetNext() []byte

func (*ReadGlobalReply) ProtoMessage Uses

func (*ReadGlobalReply) ProtoMessage()

func (*ReadGlobalReply) Reset Uses

func (m *ReadGlobalReply) Reset()

func (*ReadGlobalReply) String Uses

func (m *ReadGlobalReply) String() string

func (*ReadGlobalReply) XXX_DiscardUnknown Uses

func (m *ReadGlobalReply) XXX_DiscardUnknown()

func (*ReadGlobalReply) XXX_Marshal Uses

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

func (*ReadGlobalReply) XXX_Merge Uses

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

func (*ReadGlobalReply) XXX_Size Uses

func (m *ReadGlobalReply) XXX_Size() int

func (*ReadGlobalReply) XXX_Unmarshal Uses

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

type ReadGlobalRequest Uses

type ReadGlobalRequest struct {
    Database             string   `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
    From                 []byte   `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"`
    Limit                int32    `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*ReadGlobalRequest) Descriptor Uses

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

func (*ReadGlobalRequest) GetDatabase Uses

func (m *ReadGlobalRequest) GetDatabase() string

func (*ReadGlobalRequest) GetFrom Uses

func (m *ReadGlobalRequest) GetFrom() []byte

func (*ReadGlobalRequest) GetLimit Uses

func (m *ReadGlobalRequest) GetLimit() int32

func (*ReadGlobalRequest) ProtoMessage Uses

func (*ReadGlobalRequest) ProtoMessage()

func (*ReadGlobalRequest) Reset Uses

func (m *ReadGlobalRequest) Reset()

func (*ReadGlobalRequest) String Uses

func (m *ReadGlobalRequest) String() string

func (*ReadGlobalRequest) XXX_DiscardUnknown Uses

func (m *ReadGlobalRequest) XXX_DiscardUnknown()

func (*ReadGlobalRequest) XXX_Marshal Uses

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

func (*ReadGlobalRequest) XXX_Merge Uses

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

func (*ReadGlobalRequest) XXX_Size Uses

func (m *ReadGlobalRequest) XXX_Size() int

func (*ReadGlobalRequest) XXX_Unmarshal Uses

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

type ReadStreamRequest Uses

type ReadStreamRequest struct {
    Database             string   `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
    Stream               string   `protobuf:"bytes,2,opt,name=stream,proto3" json:"stream,omitempty"`
    From                 int64    `protobuf:"varint,3,opt,name=from,proto3" json:"from,omitempty"`
    Limit                uint32   `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
    Reverse              bool     `protobuf:"varint,5,opt,name=reverse,proto3" json:"reverse,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

The request message containing the user's name.

func (*ReadStreamRequest) Descriptor Uses

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

func (*ReadStreamRequest) GetDatabase Uses

func (m *ReadStreamRequest) GetDatabase() string

func (*ReadStreamRequest) GetFrom Uses

func (m *ReadStreamRequest) GetFrom() int64

func (*ReadStreamRequest) GetLimit Uses

func (m *ReadStreamRequest) GetLimit() uint32

func (*ReadStreamRequest) GetReverse Uses

func (m *ReadStreamRequest) GetReverse() bool

func (*ReadStreamRequest) GetStream Uses

func (m *ReadStreamRequest) GetStream() string

func (*ReadStreamRequest) ProtoMessage Uses

func (*ReadStreamRequest) ProtoMessage()

func (*ReadStreamRequest) Reset Uses

func (m *ReadStreamRequest) Reset()

func (*ReadStreamRequest) String Uses

func (m *ReadStreamRequest) String() string

func (*ReadStreamRequest) XXX_DiscardUnknown Uses

func (m *ReadStreamRequest) XXX_DiscardUnknown()

func (*ReadStreamRequest) XXX_Marshal Uses

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

func (*ReadStreamRequest) XXX_Merge Uses

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

func (*ReadStreamRequest) XXX_Size Uses

func (m *ReadStreamRequest) XXX_Size() int

func (*ReadStreamRequest) XXX_Unmarshal Uses

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

type Slice Uses

type Slice struct {
    Stream               string     `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
    From                 int64      `protobuf:"varint,2,opt,name=from,proto3" json:"from,omitempty"`
    Count                int32      `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
    Next                 int64      `protobuf:"varint,4,opt,name=next,proto3" json:"next,omitempty"`
    HasNext              bool       `protobuf:"varint,5,opt,name=hasNext,proto3" json:"hasNext,omitempty"`
    Head                 int64      `protobuf:"varint,6,opt,name=head,proto3" json:"head,omitempty"`
    Messages             []*Message `protobuf:"bytes,7,rep,name=messages,proto3" json:"messages,omitempty"`
    Reverse              bool       `protobuf:"varint,8,opt,name=reverse,proto3" json:"reverse,omitempty"`
    XXX_NoUnkeyedLiteral struct{}   `json:"-"`
    XXX_unrecognized     []byte     `json:"-"`
    XXX_sizecache        int32      `json:"-"`
}

func (*Slice) Descriptor Uses

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

func (*Slice) GetCount Uses

func (m *Slice) GetCount() int32

func (*Slice) GetFrom Uses

func (m *Slice) GetFrom() int64

func (*Slice) GetHasNext Uses

func (m *Slice) GetHasNext() bool

func (*Slice) GetHead Uses

func (m *Slice) GetHead() int64

func (*Slice) GetMessages Uses

func (m *Slice) GetMessages() []*Message

func (*Slice) GetNext Uses

func (m *Slice) GetNext() int64

func (*Slice) GetReverse Uses

func (m *Slice) GetReverse() bool

func (*Slice) GetStream Uses

func (m *Slice) GetStream() string

func (*Slice) ProtoMessage Uses

func (*Slice) ProtoMessage()

func (*Slice) Reset Uses

func (m *Slice) Reset()

func (*Slice) String Uses

func (m *Slice) String() string

func (*Slice) XXX_DiscardUnknown Uses

func (m *Slice) XXX_DiscardUnknown()

func (*Slice) XXX_Marshal Uses

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

func (*Slice) XXX_Merge Uses

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

func (*Slice) XXX_Size Uses

func (m *Slice) XXX_Size() int

func (*Slice) XXX_Unmarshal Uses

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

type StreamAppendResult Uses

type StreamAppendResult struct {
    Stream               string   `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
    Position             int64    `protobuf:"varint,2,opt,name=position,proto3" json:"position,omitempty"`
    Version              int64    `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*StreamAppendResult) Descriptor Uses

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

func (*StreamAppendResult) GetPosition Uses

func (m *StreamAppendResult) GetPosition() int64

func (*StreamAppendResult) GetStream Uses

func (m *StreamAppendResult) GetStream() string

func (*StreamAppendResult) GetVersion Uses

func (m *StreamAppendResult) GetVersion() int64

func (*StreamAppendResult) ProtoMessage Uses

func (*StreamAppendResult) ProtoMessage()

func (*StreamAppendResult) Reset Uses

func (m *StreamAppendResult) Reset()

func (*StreamAppendResult) String Uses

func (m *StreamAppendResult) String() string

func (*StreamAppendResult) XXX_DiscardUnknown Uses

func (m *StreamAppendResult) XXX_DiscardUnknown()

func (*StreamAppendResult) XXX_Marshal Uses

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

func (*StreamAppendResult) XXX_Merge Uses

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

func (*StreamAppendResult) XXX_Size Uses

func (m *StreamAppendResult) XXX_Size() int

func (*StreamAppendResult) XXX_Unmarshal Uses

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

type StreamInput Uses

type StreamInput struct {
    Database             string          `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
    Stream               string          `protobuf:"bytes,2,opt,name=stream,proto3" json:"stream,omitempty"`
    ExpectedVersion      int64           `protobuf:"varint,3,opt,name=expectedVersion,proto3" json:"expectedVersion,omitempty"`
    Messages             []*MessageInput `protobuf:"bytes,4,rep,name=messages,proto3" json:"messages,omitempty"`
    XXX_NoUnkeyedLiteral struct{}        `json:"-"`
    XXX_unrecognized     []byte          `json:"-"`
    XXX_sizecache        int32           `json:"-"`
}

func (*StreamInput) Descriptor Uses

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

func (*StreamInput) GetDatabase Uses

func (m *StreamInput) GetDatabase() string

func (*StreamInput) GetExpectedVersion Uses

func (m *StreamInput) GetExpectedVersion() int64

func (*StreamInput) GetMessages Uses

func (m *StreamInput) GetMessages() []*MessageInput

func (*StreamInput) GetStream Uses

func (m *StreamInput) GetStream() string

func (*StreamInput) ProtoMessage Uses

func (*StreamInput) ProtoMessage()

func (*StreamInput) Reset Uses

func (m *StreamInput) Reset()

func (*StreamInput) String Uses

func (m *StreamInput) String() string

func (*StreamInput) XXX_DiscardUnknown Uses

func (m *StreamInput) XXX_DiscardUnknown()

func (*StreamInput) XXX_Marshal Uses

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

func (*StreamInput) XXX_Merge Uses

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

func (*StreamInput) XXX_Size Uses

func (m *StreamInput) XXX_Size() int

func (*StreamInput) XXX_Unmarshal Uses

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

type StreamsClient Uses

type StreamsClient interface {
    GetDatabases(ctx context.Context, in *GetDatabasesRequest, opts ...grpc.CallOption) (*GetDatabasesReply, error)
    GetDatabase(ctx context.Context, in *GetDatabaseRequest, opts ...grpc.CallOption) (*GetDatabaseReply, error)
    Login(ctx context.Context, in *LoginRequest, opts ...grpc.CallOption) (*LoginReply, error)
    EnableAcl(ctx context.Context, in *EnableAclRequest, opts ...grpc.CallOption) (*EnableAclReply, error)
    GrandUserToDatabase(ctx context.Context, in *GrandUserToDatabaseRequest, opts ...grpc.CallOption) (*GrandUserToDatabaseReply, error)
    CreateUser(ctx context.Context, in *CreateUserRequest, opts ...grpc.CallOption) (*CreateUserReply, error)
    CreateDatabase(ctx context.Context, in *CreateDatabaseRequest, opts ...grpc.CallOption) (*CreateDatabaseReply, error)
    ChangePassword(ctx context.Context, in *ChangePasswordRequest, opts ...grpc.CallOption) (*ChangePasswordReply, error)
    ReadStream(ctx context.Context, in *ReadStreamRequest, opts ...grpc.CallOption) (*Slice, error)
    AppendStream(ctx context.Context, in *AppendStreamRequest, opts ...grpc.CallOption) (*AppendStreamReply, error)
    AppendStreams(ctx context.Context, in *AppendStreamsRequest, opts ...grpc.CallOption) (*AppendStreamsReply, error)
    DeleteMessage(ctx context.Context, in *DeleteMessageRequest, opts ...grpc.CallOption) (*DeleteMessageReply, error)
    DeleteStream(ctx context.Context, in *DeleteStreamRequest, opts ...grpc.CallOption) (*DeleteStreamReply, error)
    SubscribeStream(ctx context.Context, in *SubscribeStreamRequest, opts ...grpc.CallOption) (Streams_SubscribeStreamClient, error)
    ReadGlobal(ctx context.Context, in *ReadGlobalRequest, opts ...grpc.CallOption) (*ReadGlobalReply, error)
    Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingReply, error)
    GetStreams(ctx context.Context, in *GetStreamsRequest, opts ...grpc.CallOption) (*GetStreamsReply, error)
}

StreamsClient is the client API for Streams service.

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

func NewStreamsClient Uses

func NewStreamsClient(cc *grpc.ClientConn) StreamsClient

type StreamsServer Uses

type StreamsServer interface {
    GetDatabases(context.Context, *GetDatabasesRequest) (*GetDatabasesReply, error)
    GetDatabase(context.Context, *GetDatabaseRequest) (*GetDatabaseReply, error)
    Login(context.Context, *LoginRequest) (*LoginReply, error)
    EnableAcl(context.Context, *EnableAclRequest) (*EnableAclReply, error)
    GrandUserToDatabase(context.Context, *GrandUserToDatabaseRequest) (*GrandUserToDatabaseReply, error)
    CreateUser(context.Context, *CreateUserRequest) (*CreateUserReply, error)
    CreateDatabase(context.Context, *CreateDatabaseRequest) (*CreateDatabaseReply, error)
    ChangePassword(context.Context, *ChangePasswordRequest) (*ChangePasswordReply, error)
    ReadStream(context.Context, *ReadStreamRequest) (*Slice, error)
    AppendStream(context.Context, *AppendStreamRequest) (*AppendStreamReply, error)
    AppendStreams(context.Context, *AppendStreamsRequest) (*AppendStreamsReply, error)
    DeleteMessage(context.Context, *DeleteMessageRequest) (*DeleteMessageReply, error)
    DeleteStream(context.Context, *DeleteStreamRequest) (*DeleteStreamReply, error)
    SubscribeStream(*SubscribeStreamRequest, Streams_SubscribeStreamServer) error
    ReadGlobal(context.Context, *ReadGlobalRequest) (*ReadGlobalReply, error)
    Ping(context.Context, *PingRequest) (*PingReply, error)
    GetStreams(context.Context, *GetStreamsRequest) (*GetStreamsReply, error)
}

StreamsServer is the server API for Streams service.

type Streams_SubscribeStreamClient Uses

type Streams_SubscribeStreamClient interface {
    Recv() (*Slice, error)
    grpc.ClientStream
}

type Streams_SubscribeStreamServer Uses

type Streams_SubscribeStreamServer interface {
    Send(*Slice) error
    grpc.ServerStream
}

type SubscribeStreamRequest Uses

type SubscribeStreamRequest struct {
    Database             string   `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
    Stream               string   `protobuf:"bytes,2,opt,name=stream,proto3" json:"stream,omitempty"`
    From                 int64    `protobuf:"varint,3,opt,name=from,proto3" json:"from,omitempty"`
    Count                uint32   `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*SubscribeStreamRequest) Descriptor Uses

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

func (*SubscribeStreamRequest) GetCount Uses

func (m *SubscribeStreamRequest) GetCount() uint32

func (*SubscribeStreamRequest) GetDatabase Uses

func (m *SubscribeStreamRequest) GetDatabase() string

func (*SubscribeStreamRequest) GetFrom Uses

func (m *SubscribeStreamRequest) GetFrom() int64

func (*SubscribeStreamRequest) GetStream Uses

func (m *SubscribeStreamRequest) GetStream() string

func (*SubscribeStreamRequest) ProtoMessage Uses

func (*SubscribeStreamRequest) ProtoMessage()

func (*SubscribeStreamRequest) Reset Uses

func (m *SubscribeStreamRequest) Reset()

func (*SubscribeStreamRequest) String Uses

func (m *SubscribeStreamRequest) String() string

func (*SubscribeStreamRequest) XXX_DiscardUnknown Uses

func (m *SubscribeStreamRequest) XXX_DiscardUnknown()

func (*SubscribeStreamRequest) XXX_Marshal Uses

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

func (*SubscribeStreamRequest) XXX_Merge Uses

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

func (*SubscribeStreamRequest) XXX_Size Uses

func (m *SubscribeStreamRequest) XXX_Size() int

func (*SubscribeStreamRequest) XXX_Unmarshal Uses

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

type UnimplementedStreamsServer Uses

type UnimplementedStreamsServer struct {
}

UnimplementedStreamsServer can be embedded to have forward compatible implementations.

func (*UnimplementedStreamsServer) AppendStream Uses

func (*UnimplementedStreamsServer) AppendStream(ctx context.Context, req *AppendStreamRequest) (*AppendStreamReply, error)

func (*UnimplementedStreamsServer) AppendStreams Uses

func (*UnimplementedStreamsServer) AppendStreams(ctx context.Context, req *AppendStreamsRequest) (*AppendStreamsReply, error)

func (*UnimplementedStreamsServer) ChangePassword Uses

func (*UnimplementedStreamsServer) ChangePassword(ctx context.Context, req *ChangePasswordRequest) (*ChangePasswordReply, error)

func (*UnimplementedStreamsServer) CreateDatabase Uses

func (*UnimplementedStreamsServer) CreateDatabase(ctx context.Context, req *CreateDatabaseRequest) (*CreateDatabaseReply, error)

func (*UnimplementedStreamsServer) CreateUser Uses

func (*UnimplementedStreamsServer) CreateUser(ctx context.Context, req *CreateUserRequest) (*CreateUserReply, error)

func (*UnimplementedStreamsServer) DeleteMessage Uses

func (*UnimplementedStreamsServer) DeleteMessage(ctx context.Context, req *DeleteMessageRequest) (*DeleteMessageReply, error)

func (*UnimplementedStreamsServer) DeleteStream Uses

func (*UnimplementedStreamsServer) DeleteStream(ctx context.Context, req *DeleteStreamRequest) (*DeleteStreamReply, error)

func (*UnimplementedStreamsServer) EnableAcl Uses

func (*UnimplementedStreamsServer) EnableAcl(ctx context.Context, req *EnableAclRequest) (*EnableAclReply, error)

func (*UnimplementedStreamsServer) GetDatabase Uses

func (*UnimplementedStreamsServer) GetDatabase(ctx context.Context, req *GetDatabaseRequest) (*GetDatabaseReply, error)

func (*UnimplementedStreamsServer) GetDatabases Uses

func (*UnimplementedStreamsServer) GetDatabases(ctx context.Context, req *GetDatabasesRequest) (*GetDatabasesReply, error)

func (*UnimplementedStreamsServer) GetStreams Uses

func (*UnimplementedStreamsServer) GetStreams(ctx context.Context, req *GetStreamsRequest) (*GetStreamsReply, error)

func (*UnimplementedStreamsServer) GrandUserToDatabase Uses

func (*UnimplementedStreamsServer) GrandUserToDatabase(ctx context.Context, req *GrandUserToDatabaseRequest) (*GrandUserToDatabaseReply, error)

func (*UnimplementedStreamsServer) Login Uses

func (*UnimplementedStreamsServer) Login(ctx context.Context, req *LoginRequest) (*LoginReply, error)

func (*UnimplementedStreamsServer) Ping Uses

func (*UnimplementedStreamsServer) Ping(ctx context.Context, req *PingRequest) (*PingReply, error)

func (*UnimplementedStreamsServer) ReadGlobal Uses

func (*UnimplementedStreamsServer) ReadGlobal(ctx context.Context, req *ReadGlobalRequest) (*ReadGlobalReply, error)

func (*UnimplementedStreamsServer) ReadStream Uses

func (*UnimplementedStreamsServer) ReadStream(ctx context.Context, req *ReadStreamRequest) (*Slice, error)

func (*UnimplementedStreamsServer) SubscribeStream Uses

func (*UnimplementedStreamsServer) SubscribeStream(req *SubscribeStreamRequest, srv Streams_SubscribeStreamServer) error

Package api imports 8 packages (graph) and is imported by 1 packages. Updated 2019-12-14. Refresh now. Tools for package owners.