state

package
v0.0.0-...-8003af0 Latest Latest
Warning

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

 Go to latest Published: Sep 27, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const StorePluginAPIVersion = 1

Variables

View Source 
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type DeleteRequest 

type DeleteRequest 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"`
	Metadata map[string]string  `` /* 157-byte string literal not displayed */
	Options  *DeleteStateOption `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

GetRequest is the object describing a state fetch request.

func (*DeleteRequest) GetEtag 

func (x *DeleteRequest) GetEtag() string

func (*DeleteRequest) GetKey 

func (x *DeleteRequest) GetKey() string

func (*DeleteRequest) GetMetadata 

func (x *DeleteRequest) GetMetadata() map[string]string

func (*DeleteRequest) GetOptions 

func (x *DeleteRequest) GetOptions() *DeleteStateOption

func (*DeleteRequest) MarshalToSizedBufferVT 

func (m *DeleteRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DeleteRequest) MarshalToVT 

func (m *DeleteRequest) MarshalToVT(dAtA []byte) (int, error)

func (*DeleteRequest) MarshalVT 

func (m *DeleteRequest) MarshalVT() (dAtA []byte, err error)

func (*DeleteRequest) ProtoReflect 

func (x *DeleteRequest) ProtoReflect() protoreflect.Message

func (*DeleteRequest) SizeVT 

func (m *DeleteRequest) SizeVT() (n int)

func (*DeleteRequest) UnmarshalVT 

func (m *DeleteRequest) UnmarshalVT(dAtA []byte) error

type DeleteResponse 

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

func (*DeleteResponse) MarshalToSizedBufferVT 

func (m *DeleteResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DeleteResponse) MarshalToVT 

func (m *DeleteResponse) MarshalToVT(dAtA []byte) (int, error)

func (*DeleteResponse) MarshalVT 

func (m *DeleteResponse) MarshalVT() (dAtA []byte, err error)

func (*DeleteResponse) ProtoReflect 

func (x *DeleteResponse) ProtoReflect() protoreflect.Message

func (*DeleteResponse) SizeVT 

func (m *DeleteResponse) SizeVT() (n int)

func (*DeleteResponse) UnmarshalVT 

func (m *DeleteResponse) UnmarshalVT(dAtA []byte) error

type DeleteStateOption 

type DeleteStateOption 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"`
	// contains filtered or unexported fields
}

DeleteStateOption controls how a state store reacts to a delete request.

func (*DeleteStateOption) GetConcurrency 

func (x *DeleteStateOption) GetConcurrency() string

func (*DeleteStateOption) GetConsistency 

func (x *DeleteStateOption) GetConsistency() string

func (*DeleteStateOption) MarshalToSizedBufferVT 

func (m *DeleteStateOption) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DeleteStateOption) MarshalToVT 

func (m *DeleteStateOption) MarshalToVT(dAtA []byte) (int, error)

func (*DeleteStateOption) MarshalVT 

func (m *DeleteStateOption) MarshalVT() (dAtA []byte, err error)

func (*DeleteStateOption) ProtoReflect 

func (x *DeleteStateOption) ProtoReflect() protoreflect.Message

func (*DeleteStateOption) SizeVT 

func (m *DeleteStateOption) SizeVT() (n int)

func (*DeleteStateOption) UnmarshalVT 

func (m *DeleteStateOption) UnmarshalVT(dAtA []byte) error

type FeaturesRequest 

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

func (*FeaturesRequest) MarshalToSizedBufferVT 

func (m *FeaturesRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FeaturesRequest) MarshalToVT 

func (m *FeaturesRequest) MarshalToVT(dAtA []byte) (int, error)

func (*FeaturesRequest) MarshalVT 

func (m *FeaturesRequest) MarshalVT() (dAtA []byte, err error)

func (*FeaturesRequest) ProtoReflect 

func (x *FeaturesRequest) ProtoReflect() protoreflect.Message

func (*FeaturesRequest) SizeVT 

func (m *FeaturesRequest) SizeVT() (n int)

func (*FeaturesRequest) UnmarshalVT 

func (m *FeaturesRequest) UnmarshalVT(dAtA []byte) error

type FeaturesResponse 

type FeaturesResponse struct {
	Features []string `protobuf:"bytes,1,rep,name=features,proto3" json:"features,omitempty"`
	// contains filtered or unexported fields
}

func (*FeaturesResponse) GetFeatures 

func (x *FeaturesResponse) GetFeatures() []string

func (*FeaturesResponse) MarshalToSizedBufferVT 

func (m *FeaturesResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FeaturesResponse) MarshalToVT 

func (m *FeaturesResponse) MarshalToVT(dAtA []byte) (int, error)

func (*FeaturesResponse) MarshalVT 

func (m *FeaturesResponse) MarshalVT() (dAtA []byte, err error)

func (*FeaturesResponse) ProtoReflect 

func (x *FeaturesResponse) ProtoReflect() protoreflect.Message

func (*FeaturesResponse) SizeVT 

func (m *FeaturesResponse) SizeVT() (n int)

func (*FeaturesResponse) UnmarshalVT 

func (m *FeaturesResponse) UnmarshalVT(dAtA []byte) error

type GetRequest 

type GetRequest struct {
	Key      string            `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	Options  *GetStateOption   `protobuf:"bytes,3,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

GetRequest is the object describing a state fetch request.

func (*GetRequest) GetKey 

func (x *GetRequest) GetKey() string

func (*GetRequest) GetMetadata 

func (x *GetRequest) GetMetadata() map[string]string

func (*GetRequest) GetOptions 

func (x *GetRequest) GetOptions() *GetStateOption

func (*GetRequest) MarshalToSizedBufferVT 

func (m *GetRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetRequest) MarshalToVT 

func (m *GetRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetRequest) MarshalVT 

func (m *GetRequest) MarshalVT() (dAtA []byte, err error)

func (*GetRequest) ProtoReflect 

func (x *GetRequest) ProtoReflect() protoreflect.Message

func (*GetRequest) SizeVT 

func (m *GetRequest) SizeVT() (n int)

func (*GetRequest) UnmarshalVT 

func (m *GetRequest) UnmarshalVT(dAtA []byte) error

type GetResponse 

type GetResponse struct {
	Data        []byte            `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Etag        string            `protobuf:"bytes,2,opt,name=etag,proto3" json:"etag,omitempty"`
	Metadata    map[string]string `` /* 157-byte string literal not displayed */
	ContentType string            `protobuf:"bytes,4,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// contains filtered or unexported fields
}

GetResponse is the response object for getting state.

func (*GetResponse) GetContentType 

func (x *GetResponse) GetContentType() string

func (*GetResponse) GetData 

func (x *GetResponse) GetData() []byte

func (*GetResponse) GetEtag 

func (x *GetResponse) GetEtag() string

func (*GetResponse) GetMetadata 

func (x *GetResponse) GetMetadata() map[string]string

func (*GetResponse) MarshalToSizedBufferVT 

func (m *GetResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetResponse) MarshalToVT 

func (m *GetResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetResponse) MarshalVT 

func (m *GetResponse) MarshalVT() (dAtA []byte, err error)

func (*GetResponse) ProtoReflect 

func (x *GetResponse) ProtoReflect() protoreflect.Message

func (*GetResponse) SizeVT 

func (m *GetResponse) SizeVT() (n int)

func (*GetResponse) UnmarshalVT 

func (m *GetResponse) UnmarshalVT(dAtA []byte) error

type GetStateOption 

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

GetStateOption controls how a state store reacts to a get request.

func (*GetStateOption) GetConsistency 

func (x *GetStateOption) GetConsistency() string

func (*GetStateOption) MarshalToSizedBufferVT 

func (m *GetStateOption) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetStateOption) MarshalToVT 

func (m *GetStateOption) MarshalToVT(dAtA []byte) (int, error)

func (*GetStateOption) MarshalVT 

func (m *GetStateOption) MarshalVT() (dAtA []byte, err error)

func (*GetStateOption) ProtoReflect 

func (x *GetStateOption) ProtoReflect() protoreflect.Message

func (*GetStateOption) SizeVT 

func (m *GetStateOption) SizeVT() (n int)

func (*GetStateOption) UnmarshalVT 

func (m *GetStateOption) UnmarshalVT(dAtA []byte) error

type InitRequest 

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

The request message containing the user's name.

func (*InitRequest) GetMetadata 

func (x *InitRequest) GetMetadata() *Metadata

func (*InitRequest) MarshalToSizedBufferVT 

func (m *InitRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*InitRequest) MarshalToVT 

func (m *InitRequest) MarshalToVT(dAtA []byte) (int, error)

func (*InitRequest) MarshalVT 

func (m *InitRequest) MarshalVT() (dAtA []byte, err error)

func (*InitRequest) ProtoReflect 

func (x *InitRequest) ProtoReflect() protoreflect.Message

func (*InitRequest) SizeVT 

func (m *InitRequest) SizeVT() (n int)

func (*InitRequest) UnmarshalVT 

func (m *InitRequest) UnmarshalVT(dAtA []byte) error

type InitResponse 

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

The response message for the init

func (*InitResponse) MarshalToSizedBufferVT 

func (m *InitResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*InitResponse) MarshalToVT 

func (m *InitResponse) MarshalToVT(dAtA []byte) (int, error)

func (*InitResponse) MarshalVT 

func (m *InitResponse) MarshalVT() (dAtA []byte, err error)

func (*InitResponse) ProtoReflect 

func (x *InitResponse) ProtoReflect() protoreflect.Message

func (*InitResponse) SizeVT 

func (m *InitResponse) SizeVT() (n int)

func (*InitResponse) UnmarshalVT 

func (m *InitResponse) UnmarshalVT(dAtA []byte) error

type Metadata 

type Metadata struct {

	// Name is the name of the component that's being used.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Properties is the metadata properties.
	Properties map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Metadata) GetName 

func (x *Metadata) GetName() string

func (*Metadata) GetProperties 

func (x *Metadata) GetProperties() map[string]string

func (*Metadata) MarshalToSizedBufferVT 

func (m *Metadata) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Metadata) MarshalToVT 

func (m *Metadata) MarshalToVT(dAtA []byte) (int, error)

func (*Metadata) MarshalVT 

func (m *Metadata) MarshalVT() (dAtA []byte, err error)

func (*Metadata) ProtoReflect 

func (x *Metadata) ProtoReflect() protoreflect.Message

func (*Metadata) SizeVT 

func (m *Metadata) SizeVT() (n int)

func (*Metadata) UnmarshalVT 

func (m *Metadata) UnmarshalVT(dAtA []byte) error

type SetRequest 

type SetRequest struct {
	Key         string            `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Data        []byte            `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Etag        string            `protobuf:"bytes,3,opt,name=etag,proto3" json:"etag,omitempty"`
	Metadata    map[string]string `` /* 157-byte string literal not displayed */
	Options     *SetStateOption   `protobuf:"bytes,5,opt,name=options,proto3" json:"options,omitempty"`
	ContentType string            `protobuf:"bytes,6,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// contains filtered or unexported fields
}

GetRequest is the object describing a state fetch request.

func (*SetRequest) GetContentType 

func (x *SetRequest) GetContentType() string

func (*SetRequest) GetData 

func (x *SetRequest) GetData() []byte

func (*SetRequest) GetEtag 

func (x *SetRequest) GetEtag() string

func (*SetRequest) GetKey 

func (x *SetRequest) GetKey() string

func (*SetRequest) GetMetadata 

func (x *SetRequest) GetMetadata() map[string]string

func (*SetRequest) GetOptions 

func (x *SetRequest) GetOptions() *SetStateOption

func (*SetRequest) MarshalToSizedBufferVT 

func (m *SetRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SetRequest) MarshalToVT 

func (m *SetRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SetRequest) MarshalVT 

func (m *SetRequest) MarshalVT() (dAtA []byte, err error)

func (*SetRequest) ProtoReflect 

func (x *SetRequest) ProtoReflect() protoreflect.Message

func (*SetRequest) SizeVT 

func (m *SetRequest) SizeVT() (n int)

func (*SetRequest) UnmarshalVT 

func (m *SetRequest) UnmarshalVT(dAtA []byte) error

type SetResponse 

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

func (*SetResponse) MarshalToSizedBufferVT 

func (m *SetResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SetResponse) MarshalToVT 

func (m *SetResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SetResponse) MarshalVT 

func (m *SetResponse) MarshalVT() (dAtA []byte, err error)

func (*SetResponse) ProtoReflect 

func (x *SetResponse) ProtoReflect() protoreflect.Message

func (*SetResponse) SizeVT 

func (m *SetResponse) SizeVT() (n int)

func (*SetResponse) UnmarshalVT 

func (m *SetResponse) UnmarshalVT(dAtA []byte) error

type SetStateOption 

type SetStateOption 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"`
	// contains filtered or unexported fields
}

SetStateOption controls how a state store reacts to a set request.

func (*SetStateOption) GetConcurrency 

func (x *SetStateOption) GetConcurrency() string

func (*SetStateOption) GetConsistency 

func (x *SetStateOption) GetConsistency() string

func (*SetStateOption) MarshalToSizedBufferVT 

func (m *SetStateOption) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SetStateOption) MarshalToVT 

func (m *SetStateOption) MarshalToVT(dAtA []byte) (int, error)

func (*SetStateOption) MarshalVT 

func (m *SetStateOption) MarshalVT() (dAtA []byte, err error)

func (*SetStateOption) ProtoReflect 

func (x *SetStateOption) ProtoReflect() protoreflect.Message

func (*SetStateOption) SizeVT 

func (m *SetStateOption) SizeVT() (n int)

func (*SetStateOption) UnmarshalVT 

func (m *SetStateOption) UnmarshalVT(dAtA []byte) error

type Store 

type Store interface {
	// Sends a greeting
	Init(context.Context, InitRequest) (InitResponse, error)
	Features(context.Context, FeaturesRequest) (FeaturesResponse, error)
	Get(context.Context, GetRequest) (GetResponse, error)
	Set(context.Context, SetRequest) (SetResponse, error)
	Delete(context.Context, DeleteRequest) (DeleteResponse, error)
}

The Store service definition. go:plugin type=plugin version=1

type StorePlugin 

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

func NewStorePlugin 

func NewStorePlugin(ctx context.Context, opt StorePluginOption) (*StorePlugin, error)

func (*StorePlugin) Load 

func (p *StorePlugin) Load(ctx context.Context, pluginPath string) (Store, error)

type StorePluginOption 

type StorePluginOption struct {
	Stdout io.Writer
	Stderr io.Writer
	FS     fs.FS
}

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.