cloudstate

package
v1.4.4 Latest Latest
Warning

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

 Go to latest Published: Nov 29, 2021 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterKeyValueStoreServer 

func RegisterKeyValueStoreServer(s *grpc.Server, srv KeyValueStoreServer)

Types

type DeleteStateEnvelope 

type DeleteStateEnvelope struct {
	Key                  string        `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Options              *StateOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	Etag                 string        `protobuf:"bytes,3,opt,name=etag,proto3" json:"etag,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*DeleteStateEnvelope) Descriptor 

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

func (*DeleteStateEnvelope) GetEtag 

func (m *DeleteStateEnvelope) GetEtag() string

func (*DeleteStateEnvelope) GetKey 

func (m *DeleteStateEnvelope) GetKey() string

func (*DeleteStateEnvelope) GetOptions 

func (m *DeleteStateEnvelope) GetOptions() *StateOptions

func (*DeleteStateEnvelope) ProtoMessage 

func (*DeleteStateEnvelope) ProtoMessage()

func (*DeleteStateEnvelope) Reset 

func (m *DeleteStateEnvelope) Reset()

func (*DeleteStateEnvelope) String 

func (m *DeleteStateEnvelope) String() string

func (*DeleteStateEnvelope) XXX_DiscardUnknown 

func (m *DeleteStateEnvelope) XXX_DiscardUnknown()

func (*DeleteStateEnvelope) XXX_Marshal 

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

func (*DeleteStateEnvelope) XXX_Merge 

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

func (*DeleteStateEnvelope) XXX_Size 

func (m *DeleteStateEnvelope) XXX_Size() int

func (*DeleteStateEnvelope) XXX_Unmarshal 

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

type GetStateEnvelope 

type GetStateEnvelope struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Etag                 string   `protobuf:"bytes,2,opt,name=etag,proto3" json:"etag,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetStateEnvelope) Descriptor 

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

func (*GetStateEnvelope) GetEtag 

func (m *GetStateEnvelope) GetEtag() string

func (*GetStateEnvelope) GetKey 

func (m *GetStateEnvelope) GetKey() string

func (*GetStateEnvelope) ProtoMessage 

func (*GetStateEnvelope) ProtoMessage()

func (*GetStateEnvelope) Reset 

func (m *GetStateEnvelope) Reset()

func (*GetStateEnvelope) String 

func (m *GetStateEnvelope) String() string

func (*GetStateEnvelope) XXX_DiscardUnknown 

func (m *GetStateEnvelope) XXX_DiscardUnknown()

func (*GetStateEnvelope) XXX_Marshal 

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

func (*GetStateEnvelope) XXX_Merge 

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

func (*GetStateEnvelope) XXX_Size 

func (m *GetStateEnvelope) XXX_Size() int

func (*GetStateEnvelope) XXX_Unmarshal 

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

type GetStateResponseEnvelope 

type GetStateResponseEnvelope struct {
	Data                 *any.Any `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Etag                 string   `protobuf:"bytes,2,opt,name=etag,proto3" json:"etag,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetStateResponseEnvelope) Descriptor 

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

func (*GetStateResponseEnvelope) GetData 

func (m *GetStateResponseEnvelope) GetData() *any.Any

func (*GetStateResponseEnvelope) GetEtag 

func (m *GetStateResponseEnvelope) GetEtag() string

func (*GetStateResponseEnvelope) ProtoMessage 

func (*GetStateResponseEnvelope) ProtoMessage()

func (*GetStateResponseEnvelope) Reset 

func (m *GetStateResponseEnvelope) Reset()

func (*GetStateResponseEnvelope) String 

func (m *GetStateResponseEnvelope) String() string

func (*GetStateResponseEnvelope) XXX_DiscardUnknown 

func (m *GetStateResponseEnvelope) XXX_DiscardUnknown()

func (*GetStateResponseEnvelope) XXX_Marshal 

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

func (*GetStateResponseEnvelope) XXX_Merge 

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

func (*GetStateResponseEnvelope) XXX_Size 

func (m *GetStateResponseEnvelope) XXX_Size() int

func (*GetStateResponseEnvelope) XXX_Unmarshal 

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

type KeyValueStoreClient 

type KeyValueStoreClient interface {
	GetState(ctx context.Context, in *GetStateEnvelope, opts ...grpc.CallOption) (*GetStateResponseEnvelope, error)
	SaveState(ctx context.Context, in *SaveStateEnvelope, opts ...grpc.CallOption) (*empty.Empty, error)
	DeleteState(ctx context.Context, in *DeleteStateEnvelope, opts ...grpc.CallOption) (*empty.Empty, error)
}

KeyValueStoreClient is the client API for KeyValueStore service.

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

func NewKeyValueStoreClient 

func NewKeyValueStoreClient(cc *grpc.ClientConn) KeyValueStoreClient

type KeyValueStoreServer 

type KeyValueStoreServer interface {
	GetState(context.Context, *GetStateEnvelope) (*GetStateResponseEnvelope, error)
	SaveState(context.Context, *SaveStateEnvelope) (*empty.Empty, error)
	DeleteState(context.Context, *DeleteStateEnvelope) (*empty.Empty, error)
}

KeyValueStoreServer is the server API for KeyValueStore service.

type SaveStateEnvelope 

type SaveStateEnvelope struct {
	Key                  string               `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                *any.Any             `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Etag                 string               `protobuf:"bytes,3,opt,name=etag,proto3" json:"etag,omitempty"`
	Metadata             map[string]string    `` /* 157-byte string literal not displayed */
	Options              *StateRequestOptions `protobuf:"bytes,5,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*SaveStateEnvelope) Descriptor 

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

func (*SaveStateEnvelope) GetEtag 

func (m *SaveStateEnvelope) GetEtag() string

func (*SaveStateEnvelope) GetKey 

func (m *SaveStateEnvelope) GetKey() string

func (*SaveStateEnvelope) GetMetadata 

func (m *SaveStateEnvelope) GetMetadata() map[string]string

func (*SaveStateEnvelope) GetOptions 

func (m *SaveStateEnvelope) GetOptions() *StateRequestOptions

func (*SaveStateEnvelope) GetValue 

func (m *SaveStateEnvelope) GetValue() *any.Any

func (*SaveStateEnvelope) ProtoMessage 

func (*SaveStateEnvelope) ProtoMessage()

func (*SaveStateEnvelope) Reset 

func (m *SaveStateEnvelope) Reset()

func (*SaveStateEnvelope) String 

func (m *SaveStateEnvelope) String() string

func (*SaveStateEnvelope) XXX_DiscardUnknown 

func (m *SaveStateEnvelope) XXX_DiscardUnknown()

func (*SaveStateEnvelope) XXX_Marshal 

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

func (*SaveStateEnvelope) XXX_Merge 

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

func (*SaveStateEnvelope) XXX_Size 

func (m *SaveStateEnvelope) XXX_Size() int

func (*SaveStateEnvelope) XXX_Unmarshal 

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

type StateOptions 

type StateOptions struct {
	Concurrency          string   `protobuf:"bytes,1,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	Consistency          string   `protobuf:"bytes,2,opt,name=consistency,proto3" json:"consistency,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StateOptions) Descriptor 

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

func (*StateOptions) GetConcurrency 

func (m *StateOptions) GetConcurrency() string

func (*StateOptions) GetConsistency 

func (m *StateOptions) GetConsistency() string

func (*StateOptions) ProtoMessage 

func (*StateOptions) ProtoMessage()

func (*StateOptions) Reset 

func (m *StateOptions) Reset()

func (*StateOptions) String 

func (m *StateOptions) String() string

func (*StateOptions) XXX_DiscardUnknown 

func (m *StateOptions) XXX_DiscardUnknown()

func (*StateOptions) XXX_Marshal 

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

func (*StateOptions) XXX_Merge 

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

func (*StateOptions) XXX_Size 

func (m *StateOptions) XXX_Size() int

func (*StateOptions) XXX_Unmarshal 

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

type StateRequestOptions 

type StateRequestOptions struct {
	Concurrency          string   `protobuf:"bytes,1,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	Consistency          string   `protobuf:"bytes,2,opt,name=consistency,proto3" json:"consistency,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StateRequestOptions) Descriptor 

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

func (*StateRequestOptions) GetConcurrency 

func (m *StateRequestOptions) GetConcurrency() string

func (*StateRequestOptions) GetConsistency 

func (m *StateRequestOptions) GetConsistency() string

func (*StateRequestOptions) ProtoMessage 

func (*StateRequestOptions) ProtoMessage()

func (*StateRequestOptions) Reset 

func (m *StateRequestOptions) Reset()

func (*StateRequestOptions) String 

func (m *StateRequestOptions) String() string

func (*StateRequestOptions) XXX_DiscardUnknown 

func (m *StateRequestOptions) XXX_DiscardUnknown()

func (*StateRequestOptions) XXX_Marshal 

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

func (*StateRequestOptions) XXX_Merge 

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

func (*StateRequestOptions) XXX_Size 

func (m *StateRequestOptions) XXX_Size() int

func (*StateRequestOptions) XXX_Unmarshal 

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

type UnimplementedKeyValueStoreServer 

type UnimplementedKeyValueStoreServer struct {
}

UnimplementedKeyValueStoreServer can be embedded to have forward compatible implementations.

func (*UnimplementedKeyValueStoreServer) DeleteState 

func (*UnimplementedKeyValueStoreServer) DeleteState(ctx context.Context, req *DeleteStateEnvelope) (*empty.Empty, error)

func (*UnimplementedKeyValueStoreServer) GetState 

func (*UnimplementedKeyValueStoreServer) GetState(ctx context.Context, req *GetStateEnvelope) (*GetStateResponseEnvelope, error)

func (*UnimplementedKeyValueStoreServer) SaveState 

func (*UnimplementedKeyValueStoreServer) SaveState(ctx context.Context, req *SaveStateEnvelope) (*empty.Empty, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.