api_pb

package
v0.1.7 Latest Latest
Warning

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

 Go to latest Published: Feb 10, 2020 License: MIT Imports: 7 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ListenReply_Action_name = map[int32]string{
	0: "CREATE",
	1: "SAVE",
	2: "DELETE",
}
View Source 
var ListenReply_Action_value = map[string]int32{
	"CREATE": 0,
	"SAVE":   1,
	"DELETE": 2,
}
View Source 
var ListenRequest_Filter_Action_name = map[int32]string{
	0: "ALL",
	1: "CREATE",
	2: "SAVE",
	3: "DELETE",
}
View Source 
var ListenRequest_Filter_Action_value = map[string]int32{
	"ALL":    0,
	"CREATE": 1,
	"SAVE":   2,
	"DELETE": 3,
}

Functions

func RegisterAPIServer 

func RegisterAPIServer(s *grpc.Server, srv APIServer)

Types

type APIClient 

type APIClient interface {
	NewStore(ctx context.Context, in *NewStoreRequest, opts ...grpc.CallOption) (*NewStoreReply, error)
	RegisterSchema(ctx context.Context, in *RegisterSchemaRequest, opts ...grpc.CallOption) (*RegisterSchemaReply, error)
	Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartReply, error)
	StartFromAddress(ctx context.Context, in *StartFromAddressRequest, opts ...grpc.CallOption) (*StartFromAddressReply, error)
	GetStoreLink(ctx context.Context, in *GetStoreLinkRequest, opts ...grpc.CallOption) (*GetStoreLinkReply, error)
	ModelCreate(ctx context.Context, in *ModelCreateRequest, opts ...grpc.CallOption) (*ModelCreateReply, error)
	ModelSave(ctx context.Context, in *ModelSaveRequest, opts ...grpc.CallOption) (*ModelSaveReply, error)
	ModelDelete(ctx context.Context, in *ModelDeleteRequest, opts ...grpc.CallOption) (*ModelDeleteReply, error)
	ModelHas(ctx context.Context, in *ModelHasRequest, opts ...grpc.CallOption) (*ModelHasReply, error)
	ModelFind(ctx context.Context, in *ModelFindRequest, opts ...grpc.CallOption) (*ModelFindReply, error)
	ModelFindByID(ctx context.Context, in *ModelFindByIDRequest, opts ...grpc.CallOption) (*ModelFindByIDReply, error)
	ReadTransaction(ctx context.Context, opts ...grpc.CallOption) (API_ReadTransactionClient, error)
	WriteTransaction(ctx context.Context, opts ...grpc.CallOption) (API_WriteTransactionClient, error)
	Listen(ctx context.Context, in *ListenRequest, opts ...grpc.CallOption) (API_ListenClient, error)
}

APIClient is the client API for API service.

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

func NewAPIClient 

func NewAPIClient(cc *grpc.ClientConn) APIClient

type APIServer 

type APIServer interface {
	NewStore(context.Context, *NewStoreRequest) (*NewStoreReply, error)
	RegisterSchema(context.Context, *RegisterSchemaRequest) (*RegisterSchemaReply, error)
	Start(context.Context, *StartRequest) (*StartReply, error)
	StartFromAddress(context.Context, *StartFromAddressRequest) (*StartFromAddressReply, error)
	GetStoreLink(context.Context, *GetStoreLinkRequest) (*GetStoreLinkReply, error)
	ModelCreate(context.Context, *ModelCreateRequest) (*ModelCreateReply, error)
	ModelSave(context.Context, *ModelSaveRequest) (*ModelSaveReply, error)
	ModelDelete(context.Context, *ModelDeleteRequest) (*ModelDeleteReply, error)
	ModelHas(context.Context, *ModelHasRequest) (*ModelHasReply, error)
	ModelFind(context.Context, *ModelFindRequest) (*ModelFindReply, error)
	ModelFindByID(context.Context, *ModelFindByIDRequest) (*ModelFindByIDReply, error)
	ReadTransaction(API_ReadTransactionServer) error
	WriteTransaction(API_WriteTransactionServer) error
	Listen(*ListenRequest, API_ListenServer) error
}

APIServer is the server API for API service.

type API_ListenClient 

type API_ListenClient interface {
	Recv() (*ListenReply, error)
	grpc.ClientStream
}

type API_ListenServer 

type API_ListenServer interface {
	Send(*ListenReply) error
	grpc.ServerStream
}

type API_ReadTransactionClient 

type API_ReadTransactionClient interface {
	Send(*ReadTransactionRequest) error
	Recv() (*ReadTransactionReply, error)
	grpc.ClientStream
}

type API_ReadTransactionServer 

type API_ReadTransactionServer interface {
	Send(*ReadTransactionReply) error
	Recv() (*ReadTransactionRequest, error)
	grpc.ServerStream
}

type API_WriteTransactionClient 

type API_WriteTransactionClient interface {
	Send(*WriteTransactionRequest) error
	Recv() (*WriteTransactionReply, error)
	grpc.ClientStream
}

type API_WriteTransactionServer 

type API_WriteTransactionServer interface {
	Send(*WriteTransactionReply) error
	Recv() (*WriteTransactionRequest, error)
	grpc.ServerStream
}

type GetStoreLinkReply 

type GetStoreLinkReply struct {
	Addresses            []string `protobuf:"bytes,1,rep,name=addresses,proto3" json:"addresses,omitempty"`
	FollowKey            []byte   `protobuf:"bytes,2,opt,name=followKey,proto3" json:"followKey,omitempty"`
	ReadKey              []byte   `protobuf:"bytes,3,opt,name=readKey,proto3" json:"readKey,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetStoreLinkReply) Descriptor 

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

func (*GetStoreLinkReply) GetAddresses 

func (m *GetStoreLinkReply) GetAddresses() []string

func (*GetStoreLinkReply) GetFollowKey 

func (m *GetStoreLinkReply) GetFollowKey() []byte

func (*GetStoreLinkReply) GetReadKey 

func (m *GetStoreLinkReply) GetReadKey() []byte

func (*GetStoreLinkReply) ProtoMessage 

func (*GetStoreLinkReply) ProtoMessage()

func (*GetStoreLinkReply) Reset 

func (m *GetStoreLinkReply) Reset()

func (*GetStoreLinkReply) String 

func (m *GetStoreLinkReply) String() string

func (*GetStoreLinkReply) XXX_DiscardUnknown 

func (m *GetStoreLinkReply) XXX_DiscardUnknown()

func (*GetStoreLinkReply) XXX_Marshal 

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

func (*GetStoreLinkReply) XXX_Merge 

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

func (*GetStoreLinkReply) XXX_Size 

func (m *GetStoreLinkReply) XXX_Size() int

func (*GetStoreLinkReply) XXX_Unmarshal 

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

type GetStoreLinkRequest 

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

func (*GetStoreLinkRequest) Descriptor 

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

func (*GetStoreLinkRequest) GetStoreID 

func (m *GetStoreLinkRequest) GetStoreID() string

func (*GetStoreLinkRequest) ProtoMessage 

func (*GetStoreLinkRequest) ProtoMessage()

func (*GetStoreLinkRequest) Reset 

func (m *GetStoreLinkRequest) Reset()

func (*GetStoreLinkRequest) String 

func (m *GetStoreLinkRequest) String() string

func (*GetStoreLinkRequest) XXX_DiscardUnknown 

func (m *GetStoreLinkRequest) XXX_DiscardUnknown()

func (*GetStoreLinkRequest) XXX_Marshal 

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

func (*GetStoreLinkRequest) XXX_Merge 

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

func (*GetStoreLinkRequest) XXX_Size 

func (m *GetStoreLinkRequest) XXX_Size() int

func (*GetStoreLinkRequest) XXX_Unmarshal 

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

type ListenReply 

type ListenReply struct {
	ModelName            string             `protobuf:"bytes,1,opt,name=modelName,proto3" json:"modelName,omitempty"`
	EntityID             string             `protobuf:"bytes,2,opt,name=entityID,proto3" json:"entityID,omitempty"`
	Action               ListenReply_Action `protobuf:"varint,3,opt,name=action,proto3,enum=api.pb.ListenReply_Action" json:"action,omitempty"`
	Entity               []byte             `protobuf:"bytes,4,opt,name=entity,proto3" json:"entity,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ListenReply) Descriptor 

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

func (*ListenReply) GetAction 

func (m *ListenReply) GetAction() ListenReply_Action

func (*ListenReply) GetEntity 

func (m *ListenReply) GetEntity() []byte

func (*ListenReply) GetEntityID 

func (m *ListenReply) GetEntityID() string

func (*ListenReply) GetModelName 

func (m *ListenReply) GetModelName() string

func (*ListenReply) ProtoMessage 

func (*ListenReply) ProtoMessage()

func (*ListenReply) Reset 

func (m *ListenReply) Reset()

func (*ListenReply) String 

func (m *ListenReply) String() string

func (*ListenReply) XXX_DiscardUnknown 

func (m *ListenReply) XXX_DiscardUnknown()

func (*ListenReply) XXX_Marshal 

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

func (*ListenReply) XXX_Merge 

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

func (*ListenReply) XXX_Size 

func (m *ListenReply) XXX_Size() int

func (*ListenReply) XXX_Unmarshal 

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

type ListenReply_Action 

type ListenReply_Action int32
const (
	ListenReply_CREATE ListenReply_Action = 0
	ListenReply_SAVE   ListenReply_Action = 1
	ListenReply_DELETE ListenReply_Action = 2
)

func (ListenReply_Action) EnumDescriptor 

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

func (ListenReply_Action) String 

func (x ListenReply_Action) String() string

type ListenRequest 

type ListenRequest struct {
	StoreID              string                  `protobuf:"bytes,1,opt,name=storeID,proto3" json:"storeID,omitempty"`
	Filters              []*ListenRequest_Filter `protobuf:"bytes,2,rep,name=filters,proto3" json:"filters,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*ListenRequest) Descriptor 

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

func (*ListenRequest) GetFilters 

func (m *ListenRequest) GetFilters() []*ListenRequest_Filter

func (*ListenRequest) GetStoreID 

func (m *ListenRequest) GetStoreID() string

func (*ListenRequest) ProtoMessage 

func (*ListenRequest) ProtoMessage()

func (*ListenRequest) Reset 

func (m *ListenRequest) Reset()

func (*ListenRequest) String 

func (m *ListenRequest) String() string

func (*ListenRequest) XXX_DiscardUnknown 

func (m *ListenRequest) XXX_DiscardUnknown()

func (*ListenRequest) XXX_Marshal 

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

func (*ListenRequest) XXX_Merge 

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

func (*ListenRequest) XXX_Size 

func (m *ListenRequest) XXX_Size() int

func (*ListenRequest) XXX_Unmarshal 

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

type ListenRequest_Filter 

type ListenRequest_Filter struct {
	ModelName            string                      `protobuf:"bytes,1,opt,name=modelName,proto3" json:"modelName,omitempty"`
	EntityID             string                      `protobuf:"bytes,2,opt,name=entityID,proto3" json:"entityID,omitempty"`
	Action               ListenRequest_Filter_Action `protobuf:"varint,3,opt,name=action,proto3,enum=api.pb.ListenRequest_Filter_Action" json:"action,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*ListenRequest_Filter) Descriptor 

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

func (*ListenRequest_Filter) GetAction 

func (m *ListenRequest_Filter) GetAction() ListenRequest_Filter_Action

func (*ListenRequest_Filter) GetEntityID 

func (m *ListenRequest_Filter) GetEntityID() string

func (*ListenRequest_Filter) GetModelName 

func (m *ListenRequest_Filter) GetModelName() string

func (*ListenRequest_Filter) ProtoMessage 

func (*ListenRequest_Filter) ProtoMessage()

func (*ListenRequest_Filter) Reset 

func (m *ListenRequest_Filter) Reset()

func (*ListenRequest_Filter) String 

func (m *ListenRequest_Filter) String() string

func (*ListenRequest_Filter) XXX_DiscardUnknown 

func (m *ListenRequest_Filter) XXX_DiscardUnknown()

func (*ListenRequest_Filter) XXX_Marshal 

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

func (*ListenRequest_Filter) XXX_Merge 

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

func (*ListenRequest_Filter) XXX_Size 

func (m *ListenRequest_Filter) XXX_Size() int

func (*ListenRequest_Filter) XXX_Unmarshal 

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

type ListenRequest_Filter_Action 

type ListenRequest_Filter_Action int32
const (
	ListenRequest_Filter_ALL    ListenRequest_Filter_Action = 0
	ListenRequest_Filter_CREATE ListenRequest_Filter_Action = 1
	ListenRequest_Filter_SAVE   ListenRequest_Filter_Action = 2
	ListenRequest_Filter_DELETE ListenRequest_Filter_Action = 3
)

func (ListenRequest_Filter_Action) EnumDescriptor 

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

func (ListenRequest_Filter_Action) String 

func (x ListenRequest_Filter_Action) String() string

type ModelCreateReply 

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

func (*ModelCreateReply) Descriptor 

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

func (*ModelCreateReply) GetEntities 

func (m *ModelCreateReply) GetEntities() []string

func (*ModelCreateReply) ProtoMessage 

func (*ModelCreateReply) ProtoMessage()

func (*ModelCreateReply) Reset 

func (m *ModelCreateReply) Reset()

func (*ModelCreateReply) String 

func (m *ModelCreateReply) String() string

func (*ModelCreateReply) XXX_DiscardUnknown 

func (m *ModelCreateReply) XXX_DiscardUnknown()

func (*ModelCreateReply) XXX_Marshal 

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

func (*ModelCreateReply) XXX_Merge 

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

func (*ModelCreateReply) XXX_Size 

func (m *ModelCreateReply) XXX_Size() int

func (*ModelCreateReply) XXX_Unmarshal 

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

type ModelCreateRequest 

type ModelCreateRequest struct {
	StoreID              string   `protobuf:"bytes,1,opt,name=storeID,proto3" json:"storeID,omitempty"`
	ModelName            string   `protobuf:"bytes,2,opt,name=modelName,proto3" json:"modelName,omitempty"`
	Values               []string `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ModelCreateRequest) Descriptor 

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

func (*ModelCreateRequest) GetModelName 

func (m *ModelCreateRequest) GetModelName() string

func (*ModelCreateRequest) GetStoreID 

func (m *ModelCreateRequest) GetStoreID() string

func (*ModelCreateRequest) GetValues 

func (m *ModelCreateRequest) GetValues() []string

func (*ModelCreateRequest) ProtoMessage 

func (*ModelCreateRequest) ProtoMessage()

func (*ModelCreateRequest) Reset 

func (m *ModelCreateRequest) Reset()

func (*ModelCreateRequest) String 

func (m *ModelCreateRequest) String() string

func (*ModelCreateRequest) XXX_DiscardUnknown 

func (m *ModelCreateRequest) XXX_DiscardUnknown()

func (*ModelCreateRequest) XXX_Marshal 

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

func (*ModelCreateRequest) XXX_Merge 

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

func (*ModelCreateRequest) XXX_Size 

func (m *ModelCreateRequest) XXX_Size() int

func (*ModelCreateRequest) XXX_Unmarshal 

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

type ModelDeleteReply 

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

func (*ModelDeleteReply) Descriptor 

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

func (*ModelDeleteReply) ProtoMessage 

func (*ModelDeleteReply) ProtoMessage()

func (*ModelDeleteReply) Reset 

func (m *ModelDeleteReply) Reset()

func (*ModelDeleteReply) String 

func (m *ModelDeleteReply) String() string

func (*ModelDeleteReply) XXX_DiscardUnknown 

func (m *ModelDeleteReply) XXX_DiscardUnknown()

func (*ModelDeleteReply) XXX_Marshal 

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

func (*ModelDeleteReply) XXX_Merge 

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

func (*ModelDeleteReply) XXX_Size 

func (m *ModelDeleteReply) XXX_Size() int

func (*ModelDeleteReply) XXX_Unmarshal 

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

type ModelDeleteRequest 

type ModelDeleteRequest struct {
	StoreID              string   `protobuf:"bytes,1,opt,name=storeID,proto3" json:"storeID,omitempty"`
	ModelName            string   `protobuf:"bytes,2,opt,name=modelName,proto3" json:"modelName,omitempty"`
	EntityIDs            []string `protobuf:"bytes,3,rep,name=entityIDs,proto3" json:"entityIDs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ModelDeleteRequest) Descriptor 

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

func (*ModelDeleteRequest) GetEntityIDs 

func (m *ModelDeleteRequest) GetEntityIDs() []string

func (*ModelDeleteRequest) GetModelName 

func (m *ModelDeleteRequest) GetModelName() string

func (*ModelDeleteRequest) GetStoreID 

func (m *ModelDeleteRequest) GetStoreID() string

func (*ModelDeleteRequest) ProtoMessage 

func (*ModelDeleteRequest) ProtoMessage()

func (*ModelDeleteRequest) Reset 

func (m *ModelDeleteRequest) Reset()

func (*ModelDeleteRequest) String 

func (m *ModelDeleteRequest) String() string

func (*ModelDeleteRequest) XXX_DiscardUnknown 

func (m *ModelDeleteRequest) XXX_DiscardUnknown()

func (*ModelDeleteRequest) XXX_Marshal 

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

func (*ModelDeleteRequest) XXX_Merge 

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

func (*ModelDeleteRequest) XXX_Size 

func (m *ModelDeleteRequest) XXX_Size() int

func (*ModelDeleteRequest) XXX_Unmarshal 

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

type ModelFindByIDReply 

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

func (*ModelFindByIDReply) Descriptor 

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

func (*ModelFindByIDReply) GetEntity 

func (m *ModelFindByIDReply) GetEntity() string

func (*ModelFindByIDReply) ProtoMessage 

func (*ModelFindByIDReply) ProtoMessage()

func (*ModelFindByIDReply) Reset 

func (m *ModelFindByIDReply) Reset()

func (*ModelFindByIDReply) String 

func (m *ModelFindByIDReply) String() string

func (*ModelFindByIDReply) XXX_DiscardUnknown 

func (m *ModelFindByIDReply) XXX_DiscardUnknown()

func (*ModelFindByIDReply) XXX_Marshal 

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

func (*ModelFindByIDReply) XXX_Merge 

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

func (*ModelFindByIDReply) XXX_Size 

func (m *ModelFindByIDReply) XXX_Size() int

func (*ModelFindByIDReply) XXX_Unmarshal 

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

type ModelFindByIDRequest 

type ModelFindByIDRequest struct {
	StoreID              string   `protobuf:"bytes,1,opt,name=storeID,proto3" json:"storeID,omitempty"`
	ModelName            string   `protobuf:"bytes,2,opt,name=modelName,proto3" json:"modelName,omitempty"`
	EntityID             string   `protobuf:"bytes,3,opt,name=entityID,proto3" json:"entityID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ModelFindByIDRequest) Descriptor 

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

func (*ModelFindByIDRequest) GetEntityID 

func (m *ModelFindByIDRequest) GetEntityID() string

func (*ModelFindByIDRequest) GetModelName 

func (m *ModelFindByIDRequest) GetModelName() string

func (*ModelFindByIDRequest) GetStoreID 

func (m *ModelFindByIDRequest) GetStoreID() string

func (*ModelFindByIDRequest) ProtoMessage 

func (*ModelFindByIDRequest) ProtoMessage()

func (*ModelFindByIDRequest) Reset 

func (m *ModelFindByIDRequest) Reset()

func (*ModelFindByIDRequest) String 

func (m *ModelFindByIDRequest) String() string

func (*ModelFindByIDRequest) XXX_DiscardUnknown 

func (m *ModelFindByIDRequest) XXX_DiscardUnknown()

func (*ModelFindByIDRequest) XXX_Marshal 

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

func (*ModelFindByIDRequest) XXX_Merge 

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

func (*ModelFindByIDRequest) XXX_Size 

func (m *ModelFindByIDRequest) XXX_Size() int

func (*ModelFindByIDRequest) XXX_Unmarshal 

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

type ModelFindReply 

type ModelFindReply struct {
	Entities             [][]byte `protobuf:"bytes,1,rep,name=entities,proto3" json:"entities,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ModelFindReply) Descriptor 

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

func (*ModelFindReply) GetEntities 

func (m *ModelFindReply) GetEntities() [][]byte

func (*ModelFindReply) ProtoMessage 

func (*ModelFindReply) ProtoMessage()

func (*ModelFindReply) Reset 

func (m *ModelFindReply) Reset()

func (*ModelFindReply) String 

func (m *ModelFindReply) String() string

func (*ModelFindReply) XXX_DiscardUnknown 

func (m *ModelFindReply) XXX_DiscardUnknown()

func (*ModelFindReply) XXX_Marshal 

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

func (*ModelFindReply) XXX_Merge 

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

func (*ModelFindReply) XXX_Size 

func (m *ModelFindReply) XXX_Size() int

func (*ModelFindReply) XXX_Unmarshal 

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

type ModelFindRequest 

type ModelFindRequest struct {
	StoreID              string   `protobuf:"bytes,1,opt,name=storeID,proto3" json:"storeID,omitempty"`
	ModelName            string   `protobuf:"bytes,2,opt,name=modelName,proto3" json:"modelName,omitempty"`
	QueryJSON            []byte   `protobuf:"bytes,3,opt,name=queryJSON,proto3" json:"queryJSON,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ModelFindRequest) Descriptor 

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

func (*ModelFindRequest) GetModelName 

func (m *ModelFindRequest) GetModelName() string

func (*ModelFindRequest) GetQueryJSON 

func (m *ModelFindRequest) GetQueryJSON() []byte

func (*ModelFindRequest) GetStoreID 

func (m *ModelFindRequest) GetStoreID() string

func (*ModelFindRequest) ProtoMessage 

func (*ModelFindRequest) ProtoMessage()

func (*ModelFindRequest) Reset 

func (m *ModelFindRequest) Reset()

func (*ModelFindRequest) String 

func (m *ModelFindRequest) String() string

func (*ModelFindRequest) XXX_DiscardUnknown 

func (m *ModelFindRequest) XXX_DiscardUnknown()

func (*ModelFindRequest) XXX_Marshal 

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

func (*ModelFindRequest) XXX_Merge 

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

func (*ModelFindRequest) XXX_Size 

func (m *ModelFindRequest) XXX_Size() int

func (*ModelFindRequest) XXX_Unmarshal 

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

type ModelHasReply 

type ModelHasReply struct {
	Exists               bool     `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ModelHasReply) Descriptor 

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

func (*ModelHasReply) GetExists 

func (m *ModelHasReply) GetExists() bool

func (*ModelHasReply) ProtoMessage 

func (*ModelHasReply) ProtoMessage()

func (*ModelHasReply) Reset 

func (m *ModelHasReply) Reset()

func (*ModelHasReply) String 

func (m *ModelHasReply) String() string

func (*ModelHasReply) XXX_DiscardUnknown 

func (m *ModelHasReply) XXX_DiscardUnknown()

func (*ModelHasReply) XXX_Marshal 

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

func (*ModelHasReply) XXX_Merge 

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

func (*ModelHasReply) XXX_Size 

func (m *ModelHasReply) XXX_Size() int

func (*ModelHasReply) XXX_Unmarshal 

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

type ModelHasRequest 

type ModelHasRequest struct {
	StoreID              string   `protobuf:"bytes,1,opt,name=storeID,proto3" json:"storeID,omitempty"`
	ModelName            string   `protobuf:"bytes,2,opt,name=modelName,proto3" json:"modelName,omitempty"`
	EntityIDs            []string `protobuf:"bytes,3,rep,name=entityIDs,proto3" json:"entityIDs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ModelHasRequest) Descriptor 

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

func (*ModelHasRequest) GetEntityIDs 

func (m *ModelHasRequest) GetEntityIDs() []string

func (*ModelHasRequest) GetModelName 

func (m *ModelHasRequest) GetModelName() string

func (*ModelHasRequest) GetStoreID 

func (m *ModelHasRequest) GetStoreID() string

func (*ModelHasRequest) ProtoMessage 

func (*ModelHasRequest) ProtoMessage()

func (*ModelHasRequest) Reset 

func (m *ModelHasRequest) Reset()

func (*ModelHasRequest) String 

func (m *ModelHasRequest) String() string

func (*ModelHasRequest) XXX_DiscardUnknown 

func (m *ModelHasRequest) XXX_DiscardUnknown()

func (*ModelHasRequest) XXX_Marshal 

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

func (*ModelHasRequest) XXX_Merge 

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

func (*ModelHasRequest) XXX_Size 

func (m *ModelHasRequest) XXX_Size() int

func (*ModelHasRequest) XXX_Unmarshal 

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

type ModelSaveReply 

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

func (*ModelSaveReply) Descriptor 

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

func (*ModelSaveReply) ProtoMessage 

func (*ModelSaveReply) ProtoMessage()

func (*ModelSaveReply) Reset 

func (m *ModelSaveReply) Reset()

func (*ModelSaveReply) String 

func (m *ModelSaveReply) String() string

func (*ModelSaveReply) XXX_DiscardUnknown 

func (m *ModelSaveReply) XXX_DiscardUnknown()

func (*ModelSaveReply) XXX_Marshal 

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

func (*ModelSaveReply) XXX_Merge 

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

func (*ModelSaveReply) XXX_Size 

func (m *ModelSaveReply) XXX_Size() int

func (*ModelSaveReply) XXX_Unmarshal 

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

type ModelSaveRequest 

type ModelSaveRequest struct {
	StoreID              string   `protobuf:"bytes,1,opt,name=storeID,proto3" json:"storeID,omitempty"`
	ModelName            string   `protobuf:"bytes,2,opt,name=modelName,proto3" json:"modelName,omitempty"`
	Values               []string `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ModelSaveRequest) Descriptor 

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

func (*ModelSaveRequest) GetModelName 

func (m *ModelSaveRequest) GetModelName() string

func (*ModelSaveRequest) GetStoreID 

func (m *ModelSaveRequest) GetStoreID() string

func (*ModelSaveRequest) GetValues 

func (m *ModelSaveRequest) GetValues() []string

func (*ModelSaveRequest) ProtoMessage 

func (*ModelSaveRequest) ProtoMessage()

func (*ModelSaveRequest) Reset 

func (m *ModelSaveRequest) Reset()

func (*ModelSaveRequest) String 

func (m *ModelSaveRequest) String() string

func (*ModelSaveRequest) XXX_DiscardUnknown 

func (m *ModelSaveRequest) XXX_DiscardUnknown()

func (*ModelSaveRequest) XXX_Marshal 

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

func (*ModelSaveRequest) XXX_Merge 

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

func (*ModelSaveRequest) XXX_Size 

func (m *ModelSaveRequest) XXX_Size() int

func (*ModelSaveRequest) XXX_Unmarshal 

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

type NewStoreReply 

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

func (*NewStoreReply) Descriptor 

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

func (*NewStoreReply) GetID 

func (m *NewStoreReply) GetID() string

func (*NewStoreReply) ProtoMessage 

func (*NewStoreReply) ProtoMessage()

func (*NewStoreReply) Reset 

func (m *NewStoreReply) Reset()

func (*NewStoreReply) String 

func (m *NewStoreReply) String() string

func (*NewStoreReply) XXX_DiscardUnknown 

func (m *NewStoreReply) XXX_DiscardUnknown()

func (*NewStoreReply) XXX_Marshal 

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

func (*NewStoreReply) XXX_Merge 

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

func (*NewStoreReply) XXX_Size 

func (m *NewStoreReply) XXX_Size() int

func (*NewStoreReply) XXX_Unmarshal 

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

type NewStoreRequest 

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

func (*NewStoreRequest) Descriptor 

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

func (*NewStoreRequest) ProtoMessage 

func (*NewStoreRequest) ProtoMessage()

func (*NewStoreRequest) Reset 

func (m *NewStoreRequest) Reset()

func (*NewStoreRequest) String 

func (m *NewStoreRequest) String() string

func (*NewStoreRequest) XXX_DiscardUnknown 

func (m *NewStoreRequest) XXX_DiscardUnknown()

func (*NewStoreRequest) XXX_Marshal 

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

func (*NewStoreRequest) XXX_Merge 

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

func (*NewStoreRequest) XXX_Size 

func (m *NewStoreRequest) XXX_Size() int

func (*NewStoreRequest) XXX_Unmarshal 

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

type ReadTransactionReply 

type ReadTransactionReply struct {
	// Types that are valid to be assigned to Option:
	//	*ReadTransactionReply_ModelHasReply
	//	*ReadTransactionReply_ModelFindReply
	//	*ReadTransactionReply_ModelFindByIDReply
	Option               isReadTransactionReply_Option `protobuf_oneof:"option"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*ReadTransactionReply) Descriptor 

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

func (*ReadTransactionReply) GetModelFindByIDReply 

func (m *ReadTransactionReply) GetModelFindByIDReply() *ModelFindByIDReply

func (*ReadTransactionReply) GetModelFindReply 

func (m *ReadTransactionReply) GetModelFindReply() *ModelFindReply

func (*ReadTransactionReply) GetModelHasReply 

func (m *ReadTransactionReply) GetModelHasReply() *ModelHasReply

func (*ReadTransactionReply) GetOption 

func (m *ReadTransactionReply) GetOption() isReadTransactionReply_Option

func (*ReadTransactionReply) ProtoMessage 

func (*ReadTransactionReply) ProtoMessage()

func (*ReadTransactionReply) Reset 

func (m *ReadTransactionReply) Reset()

func (*ReadTransactionReply) String 

func (m *ReadTransactionReply) String() string

func (*ReadTransactionReply) XXX_DiscardUnknown 

func (m *ReadTransactionReply) XXX_DiscardUnknown()

func (*ReadTransactionReply) XXX_Marshal 

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

func (*ReadTransactionReply) XXX_Merge 

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

func (*ReadTransactionReply) XXX_OneofWrappers 

func (*ReadTransactionReply) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ReadTransactionReply) XXX_Size 

func (m *ReadTransactionReply) XXX_Size() int

func (*ReadTransactionReply) XXX_Unmarshal 

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

type ReadTransactionReply_ModelFindByIDReply 

type ReadTransactionReply_ModelFindByIDReply struct {
	ModelFindByIDReply *ModelFindByIDReply `protobuf:"bytes,3,opt,name=modelFindByIDReply,proto3,oneof"`
}

type ReadTransactionReply_ModelFindReply 

type ReadTransactionReply_ModelFindReply struct {
	ModelFindReply *ModelFindReply `protobuf:"bytes,2,opt,name=modelFindReply,proto3,oneof"`
}

type ReadTransactionReply_ModelHasReply 

type ReadTransactionReply_ModelHasReply struct {
	ModelHasReply *ModelHasReply `protobuf:"bytes,1,opt,name=modelHasReply,proto3,oneof"`
}

type ReadTransactionRequest 

type ReadTransactionRequest struct {
	// Types that are valid to be assigned to Option:
	//	*ReadTransactionRequest_StartTransactionRequest
	//	*ReadTransactionRequest_ModelHasRequest
	//	*ReadTransactionRequest_ModelFindRequest
	//	*ReadTransactionRequest_ModelFindByIDRequest
	Option               isReadTransactionRequest_Option `protobuf_oneof:"option"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*ReadTransactionRequest) Descriptor 

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

func (*ReadTransactionRequest) GetModelFindByIDRequest 

func (m *ReadTransactionRequest) GetModelFindByIDRequest() *ModelFindByIDRequest

func (*ReadTransactionRequest) GetModelFindRequest 

func (m *ReadTransactionRequest) GetModelFindRequest() *ModelFindRequest

func (*ReadTransactionRequest) GetModelHasRequest 

func (m *ReadTransactionRequest) GetModelHasRequest() *ModelHasRequest

func (*ReadTransactionRequest) GetOption 

func (m *ReadTransactionRequest) GetOption() isReadTransactionRequest_Option

func (*ReadTransactionRequest) GetStartTransactionRequest 

func (m *ReadTransactionRequest) GetStartTransactionRequest() *StartTransactionRequest

func (*ReadTransactionRequest) ProtoMessage 

func (*ReadTransactionRequest) ProtoMessage()

func (*ReadTransactionRequest) Reset 

func (m *ReadTransactionRequest) Reset()

func (*ReadTransactionRequest) String 

func (m *ReadTransactionRequest) String() string

func (*ReadTransactionRequest) XXX_DiscardUnknown 

func (m *ReadTransactionRequest) XXX_DiscardUnknown()

func (*ReadTransactionRequest) XXX_Marshal 

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

func (*ReadTransactionRequest) XXX_Merge 

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

func (*ReadTransactionRequest) XXX_OneofWrappers 

func (*ReadTransactionRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ReadTransactionRequest) XXX_Size 

func (m *ReadTransactionRequest) XXX_Size() int

func (*ReadTransactionRequest) XXX_Unmarshal 

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

type ReadTransactionRequest_ModelFindByIDRequest 

type ReadTransactionRequest_ModelFindByIDRequest struct {
	ModelFindByIDRequest *ModelFindByIDRequest `protobuf:"bytes,4,opt,name=modelFindByIDRequest,proto3,oneof"`
}

type ReadTransactionRequest_ModelFindRequest 

type ReadTransactionRequest_ModelFindRequest struct {
	ModelFindRequest *ModelFindRequest `protobuf:"bytes,3,opt,name=modelFindRequest,proto3,oneof"`
}

type ReadTransactionRequest_ModelHasRequest 

type ReadTransactionRequest_ModelHasRequest struct {
	ModelHasRequest *ModelHasRequest `protobuf:"bytes,2,opt,name=modelHasRequest,proto3,oneof"`
}

type ReadTransactionRequest_StartTransactionRequest 

type ReadTransactionRequest_StartTransactionRequest struct {
	StartTransactionRequest *StartTransactionRequest `protobuf:"bytes,1,opt,name=startTransactionRequest,proto3,oneof"`
}

type RegisterSchemaReply 

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

func (*RegisterSchemaReply) Descriptor 

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

func (*RegisterSchemaReply) ProtoMessage 

func (*RegisterSchemaReply) ProtoMessage()

func (*RegisterSchemaReply) Reset 

func (m *RegisterSchemaReply) Reset()

func (*RegisterSchemaReply) String 

func (m *RegisterSchemaReply) String() string

func (*RegisterSchemaReply) XXX_DiscardUnknown 

func (m *RegisterSchemaReply) XXX_DiscardUnknown()

func (*RegisterSchemaReply) XXX_Marshal 

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

func (*RegisterSchemaReply) XXX_Merge 

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

func (*RegisterSchemaReply) XXX_Size 

func (m *RegisterSchemaReply) XXX_Size() int

func (*RegisterSchemaReply) XXX_Unmarshal 

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

type RegisterSchemaRequest 

type RegisterSchemaRequest struct {
	StoreID              string                               `protobuf:"bytes,1,opt,name=storeID,proto3" json:"storeID,omitempty"`
	Name                 string                               `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Schema               string                               `protobuf:"bytes,3,opt,name=schema,proto3" json:"schema,omitempty"`
	Indexes              []*RegisterSchemaRequest_IndexConfig `protobuf:"bytes,4,rep,name=indexes,proto3" json:"indexes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                             `json:"-"`
	XXX_unrecognized     []byte                               `json:"-"`
	XXX_sizecache        int32                                `json:"-"`
}

func (*RegisterSchemaRequest) Descriptor 

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

func (*RegisterSchemaRequest) GetIndexes added in v0.1.6 

func (m *RegisterSchemaRequest) GetIndexes() []*RegisterSchemaRequest_IndexConfig

func (*RegisterSchemaRequest) GetName 

func (m *RegisterSchemaRequest) GetName() string

func (*RegisterSchemaRequest) GetSchema 

func (m *RegisterSchemaRequest) GetSchema() string

func (*RegisterSchemaRequest) GetStoreID 

func (m *RegisterSchemaRequest) GetStoreID() string

func (*RegisterSchemaRequest) ProtoMessage 

func (*RegisterSchemaRequest) ProtoMessage()

func (*RegisterSchemaRequest) Reset 

func (m *RegisterSchemaRequest) Reset()

func (*RegisterSchemaRequest) String 

func (m *RegisterSchemaRequest) String() string

func (*RegisterSchemaRequest) XXX_DiscardUnknown 

func (m *RegisterSchemaRequest) XXX_DiscardUnknown()

func (*RegisterSchemaRequest) XXX_Marshal 

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

func (*RegisterSchemaRequest) XXX_Merge 

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

func (*RegisterSchemaRequest) XXX_Size 

func (m *RegisterSchemaRequest) XXX_Size() int

func (*RegisterSchemaRequest) XXX_Unmarshal 

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

type RegisterSchemaRequest_IndexConfig added in v0.1.6 

type RegisterSchemaRequest_IndexConfig struct {
	Path                 string   `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Unique               bool     `protobuf:"varint,2,opt,name=unique,proto3" json:"unique,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegisterSchemaRequest_IndexConfig) Descriptor added in v0.1.6 

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

func (*RegisterSchemaRequest_IndexConfig) GetPath added in v0.1.6 

func (m *RegisterSchemaRequest_IndexConfig) GetPath() string

func (*RegisterSchemaRequest_IndexConfig) GetUnique added in v0.1.6 

func (m *RegisterSchemaRequest_IndexConfig) GetUnique() bool

func (*RegisterSchemaRequest_IndexConfig) ProtoMessage added in v0.1.6 

func (*RegisterSchemaRequest_IndexConfig) ProtoMessage()

func (*RegisterSchemaRequest_IndexConfig) Reset added in v0.1.6 

func (m *RegisterSchemaRequest_IndexConfig) Reset()

func (*RegisterSchemaRequest_IndexConfig) String added in v0.1.6 

func (m *RegisterSchemaRequest_IndexConfig) String() string

func (*RegisterSchemaRequest_IndexConfig) XXX_DiscardUnknown added in v0.1.6 

func (m *RegisterSchemaRequest_IndexConfig) XXX_DiscardUnknown()

func (*RegisterSchemaRequest_IndexConfig) XXX_Marshal added in v0.1.6 

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

func (*RegisterSchemaRequest_IndexConfig) XXX_Merge added in v0.1.6 

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

func (*RegisterSchemaRequest_IndexConfig) XXX_Size added in v0.1.6 

func (m *RegisterSchemaRequest_IndexConfig) XXX_Size() int

func (*RegisterSchemaRequest_IndexConfig) XXX_Unmarshal added in v0.1.6 

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

type StartFromAddressReply 

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

func (*StartFromAddressReply) Descriptor 

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

func (*StartFromAddressReply) ProtoMessage 

func (*StartFromAddressReply) ProtoMessage()

func (*StartFromAddressReply) Reset 

func (m *StartFromAddressReply) Reset()

func (*StartFromAddressReply) String 

func (m *StartFromAddressReply) String() string

func (*StartFromAddressReply) XXX_DiscardUnknown 

func (m *StartFromAddressReply) XXX_DiscardUnknown()

func (*StartFromAddressReply) XXX_Marshal 

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

func (*StartFromAddressReply) XXX_Merge 

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

func (*StartFromAddressReply) XXX_Size 

func (m *StartFromAddressReply) XXX_Size() int

func (*StartFromAddressReply) XXX_Unmarshal 

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

type StartFromAddressRequest 

type StartFromAddressRequest struct {
	StoreID              string   `protobuf:"bytes,1,opt,name=storeID,proto3" json:"storeID,omitempty"`
	Address              string   `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	FollowKey            []byte   `protobuf:"bytes,3,opt,name=followKey,proto3" json:"followKey,omitempty"`
	ReadKey              []byte   `protobuf:"bytes,4,opt,name=readKey,proto3" json:"readKey,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StartFromAddressRequest) Descriptor 

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

func (*StartFromAddressRequest) GetAddress 

func (m *StartFromAddressRequest) GetAddress() string

func (*StartFromAddressRequest) GetFollowKey 

func (m *StartFromAddressRequest) GetFollowKey() []byte

func (*StartFromAddressRequest) GetReadKey 

func (m *StartFromAddressRequest) GetReadKey() []byte

func (*StartFromAddressRequest) GetStoreID 

func (m *StartFromAddressRequest) GetStoreID() string

func (*StartFromAddressRequest) ProtoMessage 

func (*StartFromAddressRequest) ProtoMessage()

func (*StartFromAddressRequest) Reset 

func (m *StartFromAddressRequest) Reset()

func (*StartFromAddressRequest) String 

func (m *StartFromAddressRequest) String() string

func (*StartFromAddressRequest) XXX_DiscardUnknown 

func (m *StartFromAddressRequest) XXX_DiscardUnknown()

func (*StartFromAddressRequest) XXX_Marshal 

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

func (*StartFromAddressRequest) XXX_Merge 

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

func (*StartFromAddressRequest) XXX_Size 

func (m *StartFromAddressRequest) XXX_Size() int

func (*StartFromAddressRequest) XXX_Unmarshal 

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

type StartReply 

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

func (*StartReply) Descriptor 

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

func (*StartReply) ProtoMessage 

func (*StartReply) ProtoMessage()

func (*StartReply) Reset 

func (m *StartReply) Reset()

func (*StartReply) String 

func (m *StartReply) String() string

func (*StartReply) XXX_DiscardUnknown 

func (m *StartReply) XXX_DiscardUnknown()

func (*StartReply) XXX_Marshal 

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

func (*StartReply) XXX_Merge 

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

func (*StartReply) XXX_Size 

func (m *StartReply) XXX_Size() int

func (*StartReply) XXX_Unmarshal 

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

type StartRequest 

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

func (*StartRequest) Descriptor 

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

func (*StartRequest) GetStoreID 

func (m *StartRequest) GetStoreID() string

func (*StartRequest) ProtoMessage 

func (*StartRequest) ProtoMessage()

func (*StartRequest) Reset 

func (m *StartRequest) Reset()

func (*StartRequest) String 

func (m *StartRequest) String() string

func (*StartRequest) XXX_DiscardUnknown 

func (m *StartRequest) XXX_DiscardUnknown()

func (*StartRequest) XXX_Marshal 

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

func (*StartRequest) XXX_Merge 

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

func (*StartRequest) XXX_Size 

func (m *StartRequest) XXX_Size() int

func (*StartRequest) XXX_Unmarshal 

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

type StartTransactionRequest 

type StartTransactionRequest struct {
	StoreID              string   `protobuf:"bytes,1,opt,name=storeID,proto3" json:"storeID,omitempty"`
	ModelName            string   `protobuf:"bytes,2,opt,name=modelName,proto3" json:"modelName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StartTransactionRequest) Descriptor 

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

func (*StartTransactionRequest) GetModelName 

func (m *StartTransactionRequest) GetModelName() string

func (*StartTransactionRequest) GetStoreID 

func (m *StartTransactionRequest) GetStoreID() string

func (*StartTransactionRequest) ProtoMessage 

func (*StartTransactionRequest) ProtoMessage()

func (*StartTransactionRequest) Reset 

func (m *StartTransactionRequest) Reset()

func (*StartTransactionRequest) String 

func (m *StartTransactionRequest) String() string

func (*StartTransactionRequest) XXX_DiscardUnknown 

func (m *StartTransactionRequest) XXX_DiscardUnknown()

func (*StartTransactionRequest) XXX_Marshal 

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

func (*StartTransactionRequest) XXX_Merge 

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

func (*StartTransactionRequest) XXX_Size 

func (m *StartTransactionRequest) XXX_Size() int

func (*StartTransactionRequest) XXX_Unmarshal 

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

type UnimplementedAPIServer 

type UnimplementedAPIServer struct {
}

UnimplementedAPIServer can be embedded to have forward compatible implementations. 

func (*UnimplementedAPIServer) GetStoreLink(ctx context.Context, req *GetStoreLinkRequest) (*GetStoreLinkReply, error)

func (*UnimplementedAPIServer) Listen 

func (*UnimplementedAPIServer) Listen(req *ListenRequest, srv API_ListenServer) error

func (*UnimplementedAPIServer) ModelCreate 

func (*UnimplementedAPIServer) ModelCreate(ctx context.Context, req *ModelCreateRequest) (*ModelCreateReply, error)

func (*UnimplementedAPIServer) ModelDelete 

func (*UnimplementedAPIServer) ModelDelete(ctx context.Context, req *ModelDeleteRequest) (*ModelDeleteReply, error)

func (*UnimplementedAPIServer) ModelFind 

func (*UnimplementedAPIServer) ModelFind(ctx context.Context, req *ModelFindRequest) (*ModelFindReply, error)

func (*UnimplementedAPIServer) ModelFindByID 

func (*UnimplementedAPIServer) ModelFindByID(ctx context.Context, req *ModelFindByIDRequest) (*ModelFindByIDReply, error)

func (*UnimplementedAPIServer) ModelHas 

func (*UnimplementedAPIServer) ModelHas(ctx context.Context, req *ModelHasRequest) (*ModelHasReply, error)

func (*UnimplementedAPIServer) ModelSave 

func (*UnimplementedAPIServer) ModelSave(ctx context.Context, req *ModelSaveRequest) (*ModelSaveReply, error)

func (*UnimplementedAPIServer) NewStore 

func (*UnimplementedAPIServer) NewStore(ctx context.Context, req *NewStoreRequest) (*NewStoreReply, error)

func (*UnimplementedAPIServer) ReadTransaction 

func (*UnimplementedAPIServer) ReadTransaction(srv API_ReadTransactionServer) error

func (*UnimplementedAPIServer) RegisterSchema 

func (*UnimplementedAPIServer) RegisterSchema(ctx context.Context, req *RegisterSchemaRequest) (*RegisterSchemaReply, error)

func (*UnimplementedAPIServer) Start 

func (*UnimplementedAPIServer) Start(ctx context.Context, req *StartRequest) (*StartReply, error)

func (*UnimplementedAPIServer) StartFromAddress 

func (*UnimplementedAPIServer) StartFromAddress(ctx context.Context, req *StartFromAddressRequest) (*StartFromAddressReply, error)

func (*UnimplementedAPIServer) WriteTransaction 

func (*UnimplementedAPIServer) WriteTransaction(srv API_WriteTransactionServer) error

type WriteTransactionReply 

type WriteTransactionReply struct {
	// Types that are valid to be assigned to Option:
	//	*WriteTransactionReply_ModelCreateReply
	//	*WriteTransactionReply_ModelSaveReply
	//	*WriteTransactionReply_ModelDeleteReply
	//	*WriteTransactionReply_ModelHasReply
	//	*WriteTransactionReply_ModelFindReply
	//	*WriteTransactionReply_ModelFindByIDReply
	Option               isWriteTransactionReply_Option `protobuf_oneof:"option"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*WriteTransactionReply) Descriptor 

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

func (*WriteTransactionReply) GetModelCreateReply 

func (m *WriteTransactionReply) GetModelCreateReply() *ModelCreateReply

func (*WriteTransactionReply) GetModelDeleteReply 

func (m *WriteTransactionReply) GetModelDeleteReply() *ModelDeleteReply

func (*WriteTransactionReply) GetModelFindByIDReply 

func (m *WriteTransactionReply) GetModelFindByIDReply() *ModelFindByIDReply

func (*WriteTransactionReply) GetModelFindReply 

func (m *WriteTransactionReply) GetModelFindReply() *ModelFindReply

func (*WriteTransactionReply) GetModelHasReply 

func (m *WriteTransactionReply) GetModelHasReply() *ModelHasReply

func (*WriteTransactionReply) GetModelSaveReply 

func (m *WriteTransactionReply) GetModelSaveReply() *ModelSaveReply

func (*WriteTransactionReply) GetOption 

func (m *WriteTransactionReply) GetOption() isWriteTransactionReply_Option

func (*WriteTransactionReply) ProtoMessage 

func (*WriteTransactionReply) ProtoMessage()

func (*WriteTransactionReply) Reset 

func (m *WriteTransactionReply) Reset()

func (*WriteTransactionReply) String 

func (m *WriteTransactionReply) String() string

func (*WriteTransactionReply) XXX_DiscardUnknown 

func (m *WriteTransactionReply) XXX_DiscardUnknown()

func (*WriteTransactionReply) XXX_Marshal 

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

func (*WriteTransactionReply) XXX_Merge 

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

func (*WriteTransactionReply) XXX_OneofWrappers 

func (*WriteTransactionReply) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*WriteTransactionReply) XXX_Size 

func (m *WriteTransactionReply) XXX_Size() int

func (*WriteTransactionReply) XXX_Unmarshal 

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

type WriteTransactionReply_ModelCreateReply 

type WriteTransactionReply_ModelCreateReply struct {
	ModelCreateReply *ModelCreateReply `protobuf:"bytes,1,opt,name=modelCreateReply,proto3,oneof"`
}

type WriteTransactionReply_ModelDeleteReply 

type WriteTransactionReply_ModelDeleteReply struct {
	ModelDeleteReply *ModelDeleteReply `protobuf:"bytes,3,opt,name=modelDeleteReply,proto3,oneof"`
}

type WriteTransactionReply_ModelFindByIDReply 

type WriteTransactionReply_ModelFindByIDReply struct {
	ModelFindByIDReply *ModelFindByIDReply `protobuf:"bytes,6,opt,name=modelFindByIDReply,proto3,oneof"`
}

type WriteTransactionReply_ModelFindReply 

type WriteTransactionReply_ModelFindReply struct {
	ModelFindReply *ModelFindReply `protobuf:"bytes,5,opt,name=modelFindReply,proto3,oneof"`
}

type WriteTransactionReply_ModelHasReply 

type WriteTransactionReply_ModelHasReply struct {
	ModelHasReply *ModelHasReply `protobuf:"bytes,4,opt,name=modelHasReply,proto3,oneof"`
}

type WriteTransactionReply_ModelSaveReply 

type WriteTransactionReply_ModelSaveReply struct {
	ModelSaveReply *ModelSaveReply `protobuf:"bytes,2,opt,name=modelSaveReply,proto3,oneof"`
}

type WriteTransactionRequest 

type WriteTransactionRequest struct {
	// Types that are valid to be assigned to Option:
	//	*WriteTransactionRequest_StartTransactionRequest
	//	*WriteTransactionRequest_ModelCreateRequest
	//	*WriteTransactionRequest_ModelSaveRequest
	//	*WriteTransactionRequest_ModelDeleteRequest
	//	*WriteTransactionRequest_ModelHasRequest
	//	*WriteTransactionRequest_ModelFindRequest
	//	*WriteTransactionRequest_ModelFindByIDRequest
	Option               isWriteTransactionRequest_Option `protobuf_oneof:"option"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (*WriteTransactionRequest) Descriptor 

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

func (*WriteTransactionRequest) GetModelCreateRequest 

func (m *WriteTransactionRequest) GetModelCreateRequest() *ModelCreateRequest

func (*WriteTransactionRequest) GetModelDeleteRequest 

func (m *WriteTransactionRequest) GetModelDeleteRequest() *ModelDeleteRequest

func (*WriteTransactionRequest) GetModelFindByIDRequest 

func (m *WriteTransactionRequest) GetModelFindByIDRequest() *ModelFindByIDRequest

func (*WriteTransactionRequest) GetModelFindRequest 

func (m *WriteTransactionRequest) GetModelFindRequest() *ModelFindRequest

func (*WriteTransactionRequest) GetModelHasRequest 

func (m *WriteTransactionRequest) GetModelHasRequest() *ModelHasRequest

func (*WriteTransactionRequest) GetModelSaveRequest 

func (m *WriteTransactionRequest) GetModelSaveRequest() *ModelSaveRequest

func (*WriteTransactionRequest) GetOption 

func (m *WriteTransactionRequest) GetOption() isWriteTransactionRequest_Option

func (*WriteTransactionRequest) GetStartTransactionRequest 

func (m *WriteTransactionRequest) GetStartTransactionRequest() *StartTransactionRequest

func (*WriteTransactionRequest) ProtoMessage 

func (*WriteTransactionRequest) ProtoMessage()

func (*WriteTransactionRequest) Reset 

func (m *WriteTransactionRequest) Reset()

func (*WriteTransactionRequest) String 

func (m *WriteTransactionRequest) String() string

func (*WriteTransactionRequest) XXX_DiscardUnknown 

func (m *WriteTransactionRequest) XXX_DiscardUnknown()

func (*WriteTransactionRequest) XXX_Marshal 

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

func (*WriteTransactionRequest) XXX_Merge 

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

func (*WriteTransactionRequest) XXX_OneofWrappers 

func (*WriteTransactionRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*WriteTransactionRequest) XXX_Size 

func (m *WriteTransactionRequest) XXX_Size() int

func (*WriteTransactionRequest) XXX_Unmarshal 

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

type WriteTransactionRequest_ModelCreateRequest 

type WriteTransactionRequest_ModelCreateRequest struct {
	ModelCreateRequest *ModelCreateRequest `protobuf:"bytes,2,opt,name=modelCreateRequest,proto3,oneof"`
}

type WriteTransactionRequest_ModelDeleteRequest 

type WriteTransactionRequest_ModelDeleteRequest struct {
	ModelDeleteRequest *ModelDeleteRequest `protobuf:"bytes,4,opt,name=modelDeleteRequest,proto3,oneof"`
}

type WriteTransactionRequest_ModelFindByIDRequest 

type WriteTransactionRequest_ModelFindByIDRequest struct {
	ModelFindByIDRequest *ModelFindByIDRequest `protobuf:"bytes,7,opt,name=modelFindByIDRequest,proto3,oneof"`
}

type WriteTransactionRequest_ModelFindRequest 

type WriteTransactionRequest_ModelFindRequest struct {
	ModelFindRequest *ModelFindRequest `protobuf:"bytes,6,opt,name=modelFindRequest,proto3,oneof"`
}

type WriteTransactionRequest_ModelHasRequest 

type WriteTransactionRequest_ModelHasRequest struct {
	ModelHasRequest *ModelHasRequest `protobuf:"bytes,5,opt,name=modelHasRequest,proto3,oneof"`
}

type WriteTransactionRequest_ModelSaveRequest 

type WriteTransactionRequest_ModelSaveRequest struct {
	ModelSaveRequest *ModelSaveRequest `protobuf:"bytes,3,opt,name=modelSaveRequest,proto3,oneof"`
}

type WriteTransactionRequest_StartTransactionRequest 

type WriteTransactionRequest_StartTransactionRequest struct {
	StartTransactionRequest *StartTransactionRequest `protobuf:"bytes,1,opt,name=startTransactionRequest,proto3,oneof"`
}

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.