sqlitepb

package
v0.0.0-...-cf623d3 Latest Latest
Warning

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

 Go to latest Published: Feb 8, 2023 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SqliteName       = "temporal.sdk.sqlite.Sqlite.Sqlite"
	QueryName        = "temporal.sdk.sqlite.Sqlite.Query"
	SerializeName    = "temporal.sdk.sqlite.Sqlite.Serialize"
	UpdateName       = "temporal.sdk.sqlite.Sqlite.Update"
	ExecSignalName   = "temporal.sdk.sqlite.Sqlite.Exec"
	ExecResponseName = ExecSignalName + "-response"
)

Constants used as workflow, activity, query, and signal names.

Variables

View Source 
var File_sqlitepb_sqlite_proto protoreflect.FileDescriptor

Functions

func BuildSqlite 

func BuildSqlite(newImpl func(workflow.Context, *SqliteInput) (SqliteImpl, error)) func(ctx workflow.Context, req *SqliteOptions) error

BuildSqlite returns a function for the given impl.

func RegisterSqlite 

func RegisterSqlite(r worker.WorkflowRegistry, newImpl func(workflow.Context, *SqliteInput) (SqliteImpl, error))

RegisterSqlite registers a workflow with the given impl.

func UpdateExternal 

func UpdateExternal(ctx workflow.Context, workflowID, runID string, req *UpdateRequest) workflow.Future

Errors fail the workflow by default

Types

type CallResponseHandler 

type CallResponseHandler interface {
	// TaskQueue returns the task queue for response activities.
	TaskQueue() string

	// PrepareCall creates a new ID and channels to receive response/error.
	// Each channel only has a buffer of one and are never closed and only one is ever sent to.
	// If context is closed, the context error is returned on error channel.
	PrepareCall(ctx context.Context) (id string, chOk <-chan interface{}, chErr <-chan error)

	// AddResponseType adds an activity for the given type and ID field.
	// Does not error if activity name already exists for the same params.
	AddResponseType(activityName string, typ reflect.Type, idField string) error
}

CallResponseHandler handles activity responses.

type Client 

type Client interface {
	ExecuteSqlite(ctx context.Context, opts *client.StartWorkflowOptions, req *SqliteOptions) (SqliteRun, error)

	// GetSqlite returns an existing run started by ExecuteSqlite.
	GetSqlite(ctx context.Context, workflowID, runID string) (SqliteRun, error)

	Query(ctx context.Context, workflowID, runID string, req *QueryRequest) (*QueryResponse, error)

	Serialize(ctx context.Context, workflowID, runID string) (*SerializeResponse, error)

	// Errors fail the workflow by default
	Update(ctx context.Context, workflowID, runID string, req *UpdateRequest) error

	Exec(ctx context.Context, workflowID, runID string, req *ExecRequest) (*ExecResponse, error)
}

func NewClient 

func NewClient(opts ClientOptions) Client

NewClient creates a new Client.

type ClientOptions 

type ClientOptions struct {
	// Required client.
	Client client.Client
	// Handler that must be present for client calls to succeed.
	CallResponseHandler CallResponseHandler
}

ClientOptions are used for NewClient.

type Exec 

type Exec struct{ Channel workflow.ReceiveChannel }

func (Exec) Receive 

func (s Exec) Receive(ctx workflow.Context) *ExecRequest

Receive blocks until call is received.

func (Exec) ReceiveAsync 

func (s Exec) ReceiveAsync() *ExecRequest

ReceiveAsync returns received signal or nil if none.

func (Exec) Respond 

func (s Exec) Respond(ctx workflow.Context, opts *workflow.ActivityOptions, req *ExecRequest, resp *ExecResponse) workflow.Future

Respond sends a response. Activity options not used if request received via another workflow. If activity options needed and not present, they are taken from the context.

func (Exec) Select 

func (s Exec) Select(sel workflow.Selector, fn func(*ExecRequest)) workflow.Selector

Select adds the callback to the selector to be invoked when signal received. Callback can be nil

type ExecRequest 

type ExecRequest struct {
	Request            *StmtRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	Id                 string       `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	ResponseTaskQueue  string       `protobuf:"bytes,3,opt,name=response_task_queue,json=responseTaskQueue,proto3" json:"response_task_queue,omitempty"`
	ResponseWorkflowId string       `protobuf:"bytes,4,opt,name=response_workflow_id,json=responseWorkflowId,proto3" json:"response_workflow_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecRequest) Descriptor deprecated 

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

Deprecated: Use ExecRequest.ProtoReflect.Descriptor instead.

func (*ExecRequest) GetId 

func (x *ExecRequest) GetId() string

func (*ExecRequest) GetRequest 

func (x *ExecRequest) GetRequest() *StmtRequest

func (*ExecRequest) GetResponseTaskQueue 

func (x *ExecRequest) GetResponseTaskQueue() string

func (*ExecRequest) GetResponseWorkflowId 

func (x *ExecRequest) GetResponseWorkflowId() string

func (*ExecRequest) ProtoMessage 

func (*ExecRequest) ProtoMessage()

func (*ExecRequest) ProtoReflect 

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

func (*ExecRequest) Reset 

func (x *ExecRequest) Reset()

func (*ExecRequest) String 

func (x *ExecRequest) String() string

type ExecResponse 

type ExecResponse struct {
	Response *StmtResponse `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	Id       string        `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecResponse) Descriptor deprecated 

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

Deprecated: Use ExecResponse.ProtoReflect.Descriptor instead.

func (*ExecResponse) GetId 

func (x *ExecResponse) GetId() string

func (*ExecResponse) GetResponse 

func (x *ExecResponse) GetResponse() *StmtResponse

func (*ExecResponse) ProtoMessage 

func (*ExecResponse) ProtoMessage()

func (*ExecResponse) ProtoReflect 

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

func (*ExecResponse) Reset 

func (x *ExecResponse) Reset()

func (*ExecResponse) String 

func (x *ExecResponse) String() string

type ExecResponseExternal 

type ExecResponseExternal struct {
	Future  workflow.Future
	Channel workflow.ReceiveChannel
}

ExecResponseExternal represents a call response.

func ExecExternal 

func ExecExternal(ctx workflow.Context, workflowID, runID string, req *ExecRequest) (ExecResponseExternal, error)

func (ExecResponseExternal) Receive 

func (e ExecResponseExternal) Receive(ctx workflow.Context) *ExecResponse

Receive blocks until response is received.

func (ExecResponseExternal) ReceiveAsync 

func (e ExecResponseExternal) ReceiveAsync() *ExecResponse

ReceiveAsync returns response or nil if none.

func (ExecResponseExternal) Select 

func (e ExecResponseExternal) Select(sel workflow.Selector, fn func(*ExecResponse)) workflow.Selector

Select adds the callback to the selector to be invoked when response received. Callback can be nil

func (ExecResponseExternal) SelectSent 

func (e ExecResponseExternal) SelectSent(sel workflow.Selector, fn func(ExecResponseExternal)) workflow.Selector

SelectSent adds when a request is sent to the selector. Callback can be nil.

func (ExecResponseExternal) WaitSent 

func (e ExecResponseExternal) WaitSent(ctx workflow.Context) error

WaitSent blocks until the request is sent.

type QueryRequest 

type QueryRequest struct {
	Request *StmtRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryRequest) Descriptor deprecated 

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

Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.

func (*QueryRequest) GetRequest 

func (x *QueryRequest) GetRequest() *StmtRequest

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) ProtoReflect 

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

func (*QueryRequest) Reset 

func (x *QueryRequest) Reset()

func (*QueryRequest) String 

func (x *QueryRequest) String() string

type QueryResponse 

type QueryResponse struct {
	Response *StmtResponse `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryResponse) Descriptor deprecated 

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

Deprecated: Use QueryResponse.ProtoReflect.Descriptor instead.

func (*QueryResponse) GetResponse 

func (x *QueryResponse) GetResponse() *StmtResponse

func (*QueryResponse) ProtoMessage 

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) ProtoReflect 

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

func (*QueryResponse) Reset 

func (x *QueryResponse) Reset()

func (*QueryResponse) String 

func (x *QueryResponse) String() string

type SerializeResponse 

type SerializeResponse struct {

	// Types that are assignable to Result:
	//	*SerializeResponse_Serialized
	//	*SerializeResponse_Error
	Result isSerializeResponse_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

func (*SerializeResponse) Descriptor deprecated 

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

Deprecated: Use SerializeResponse.ProtoReflect.Descriptor instead.

func (*SerializeResponse) GetError 

func (x *SerializeResponse) GetError() string

func (*SerializeResponse) GetResult 

func (m *SerializeResponse) GetResult() isSerializeResponse_Result

func (*SerializeResponse) GetSerialized 

func (x *SerializeResponse) GetSerialized() []byte

func (*SerializeResponse) ProtoMessage 

func (*SerializeResponse) ProtoMessage()

func (*SerializeResponse) ProtoReflect 

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

func (*SerializeResponse) Reset 

func (x *SerializeResponse) Reset()

func (*SerializeResponse) String 

func (x *SerializeResponse) String() string

type SerializeResponse_Error 

type SerializeResponse_Error struct {
	Error string `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}

type SerializeResponse_Serialized 

type SerializeResponse_Serialized struct {
	Serialized []byte `protobuf:"bytes,1,opt,name=serialized,proto3,oneof"`
}

type SqliteChildRun 

type SqliteChildRun struct{ Future workflow.ChildWorkflowFuture }

SqliteChildRun is a future for the child workflow.

func SqliteChild 

func SqliteChild(ctx workflow.Context, opts *workflow.ChildWorkflowOptions, req *SqliteOptions) SqliteChildRun

SqliteChild executes a child workflow. If options not present, they are taken from the context.

func (SqliteChildRun) Exec 

func (r SqliteChildRun) Exec(ctx workflow.Context, req *ExecRequest) (ExecResponseExternal, error)

func (SqliteChildRun) Get 

func (r SqliteChildRun) Get(ctx workflow.Context) error

Get returns the completed workflow value, waiting if necessary.

func (SqliteChildRun) Select 

func (r SqliteChildRun) Select(sel workflow.Selector, fn func(SqliteChildRun)) workflow.Selector

Select adds this completion to the selector. Callback can be nil.

func (SqliteChildRun) SelectStart 

func (r SqliteChildRun) SelectStart(sel workflow.Selector, fn func(SqliteChildRun)) workflow.Selector

SelectStart adds waiting for start to the selector. Callback can be nil.

func (SqliteChildRun) Update 

func (r SqliteChildRun) Update(ctx workflow.Context, req *UpdateRequest) workflow.Future

Errors fail the workflow by default

func (SqliteChildRun) WaitStart 

func (r SqliteChildRun) WaitStart(ctx workflow.Context) (*workflow.Execution, error)

WaitStart waits for the child workflow to start.

type SqliteImpl 

type SqliteImpl interface {
	Run(workflow.Context) error

	Query(*QueryRequest) (*QueryResponse, error)

	Serialize() (*SerializeResponse, error)
}

type SqliteInput 

type SqliteInput struct {
	Req    *SqliteOptions
	Update Update
	Exec   Exec
}

SqliteInput is input provided to SqliteImpl.Run.

type SqliteOptions 

type SqliteOptions struct {

	// If empty, considered a brand new database
	Serialized []byte `protobuf:"bytes,1,opt,name=serialized,proto3" json:"serialized,omitempty"`
	// Default is 5000
	RequestsUntilContinueAsNew uint32 `` /* 146-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SqliteOptions) Descriptor deprecated 

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

Deprecated: Use SqliteOptions.ProtoReflect.Descriptor instead.

func (*SqliteOptions) GetRequestsUntilContinueAsNew 

func (x *SqliteOptions) GetRequestsUntilContinueAsNew() uint32

func (*SqliteOptions) GetSerialized 

func (x *SqliteOptions) GetSerialized() []byte

func (*SqliteOptions) ProtoMessage 

func (*SqliteOptions) ProtoMessage()

func (*SqliteOptions) ProtoReflect 

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

func (*SqliteOptions) Reset 

func (x *SqliteOptions) Reset()

func (*SqliteOptions) String 

func (x *SqliteOptions) String() string

type SqliteRun 

type SqliteRun interface {
	// ID is the workflow ID.
	ID() string

	// RunID is the workflow run ID.
	RunID() string

	// Get returns the completed workflow value, waiting if necessary.
	Get(ctx context.Context) error

	Query(ctx context.Context, req *QueryRequest) (*QueryResponse, error)

	Serialize(ctx context.Context) (*SerializeResponse, error)

	// Errors fail the workflow by default
	Update(ctx context.Context, req *UpdateRequest) error

	Exec(ctx context.Context, req *ExecRequest) (*ExecResponse, error)
}

SqliteRun represents an execution of Sqlite.

type Stmt 

type Stmt struct {
	Sql string `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"`
	// Note: indexed parameters start at 1
	IndexedParams map[uint32]*Value `` /* 189-byte string literal not displayed */
	NamedParams   map[string]*Value `` /* 182-byte string literal not displayed */
	// If this is true, the SQL can contain multiple statements but parameters are
	// not allowed
	MultiQuery bool `protobuf:"varint,4,opt,name=multi_query,json=multiQuery,proto3" json:"multi_query,omitempty"`
	// contains filtered or unexported fields
}

func (*Stmt) Descriptor deprecated 

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

Deprecated: Use Stmt.ProtoReflect.Descriptor instead.

func (*Stmt) GetIndexedParams 

func (x *Stmt) GetIndexedParams() map[uint32]*Value

func (*Stmt) GetMultiQuery 

func (x *Stmt) GetMultiQuery() bool

func (*Stmt) GetNamedParams 

func (x *Stmt) GetNamedParams() map[string]*Value

func (*Stmt) GetSql 

func (x *Stmt) GetSql() string

func (*Stmt) ProtoMessage 

func (*Stmt) ProtoMessage()

func (*Stmt) ProtoReflect 

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

func (*Stmt) Reset 

func (x *Stmt) Reset()

func (*Stmt) String 

func (x *Stmt) String() string

type StmtRequest 

type StmtRequest struct {

	// Executed only until the first error
	Stmts []*Stmt `protobuf:"bytes,1,rep,name=stmts,proto3" json:"stmts,omitempty"`
	// contains filtered or unexported fields
}

func (*StmtRequest) Descriptor deprecated 

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

Deprecated: Use StmtRequest.ProtoReflect.Descriptor instead.

func (*StmtRequest) GetStmts 

func (x *StmtRequest) GetStmts() []*Stmt

func (*StmtRequest) ProtoMessage 

func (*StmtRequest) ProtoMessage()

func (*StmtRequest) ProtoReflect 

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

func (*StmtRequest) Reset 

func (x *StmtRequest) Reset()

func (*StmtRequest) String 

func (x *StmtRequest) String() string

type StmtResponse 

type StmtResponse struct {

	// Only up to the first error
	Results []*StmtResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*StmtResponse) Descriptor deprecated 

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

Deprecated: Use StmtResponse.ProtoReflect.Descriptor instead.

func (*StmtResponse) GetResults 

func (x *StmtResponse) GetResults() []*StmtResult

func (*StmtResponse) ProtoMessage 

func (*StmtResponse) ProtoMessage()

func (*StmtResponse) ProtoReflect 

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

func (*StmtResponse) Reset 

func (x *StmtResponse) Reset()

func (*StmtResponse) String 

func (x *StmtResponse) String() string

type StmtResult 

type StmtResult struct {
	Successes []*StmtResult_Success `protobuf:"bytes,1,rep,name=successes,proto3" json:"successes,omitempty"`
	Error     *StmtResult_Error     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*StmtResult) Descriptor deprecated 

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

Deprecated: Use StmtResult.ProtoReflect.Descriptor instead.

func (*StmtResult) GetError 

func (x *StmtResult) GetError() *StmtResult_Error

func (*StmtResult) GetSuccesses 

func (x *StmtResult) GetSuccesses() []*StmtResult_Success

func (*StmtResult) ProtoMessage 

func (*StmtResult) ProtoMessage()

func (*StmtResult) ProtoReflect 

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

func (*StmtResult) Reset 

func (x *StmtResult) Reset()

func (*StmtResult) String 

func (x *StmtResult) String() string

type StmtResult_Column 

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

func (*StmtResult_Column) Descriptor deprecated 

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

Deprecated: Use StmtResult_Column.ProtoReflect.Descriptor instead.

func (*StmtResult_Column) GetName 

func (x *StmtResult_Column) GetName() string

func (*StmtResult_Column) ProtoMessage 

func (*StmtResult_Column) ProtoMessage()

func (*StmtResult_Column) ProtoReflect 

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

func (*StmtResult_Column) Reset 

func (x *StmtResult_Column) Reset()

func (*StmtResult_Column) String 

func (x *StmtResult_Column) String() string

type StmtResult_Error 

type StmtResult_Error struct {
	Code    int64  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*StmtResult_Error) Descriptor deprecated 

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

Deprecated: Use StmtResult_Error.ProtoReflect.Descriptor instead.

func (*StmtResult_Error) GetCode 

func (x *StmtResult_Error) GetCode() int64

func (*StmtResult_Error) GetMessage 

func (x *StmtResult_Error) GetMessage() string

func (*StmtResult_Error) ProtoMessage 

func (*StmtResult_Error) ProtoMessage()

func (*StmtResult_Error) ProtoReflect 

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

func (*StmtResult_Error) Reset 

func (x *StmtResult_Error) Reset()

func (*StmtResult_Error) String 

func (x *StmtResult_Error) String() string

type StmtResult_Row 

type StmtResult_Row struct {
	Values []*Value `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*StmtResult_Row) Descriptor deprecated 

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

Deprecated: Use StmtResult_Row.ProtoReflect.Descriptor instead.

func (*StmtResult_Row) GetValues 

func (x *StmtResult_Row) GetValues() []*Value

func (*StmtResult_Row) ProtoMessage 

func (*StmtResult_Row) ProtoMessage()

func (*StmtResult_Row) ProtoReflect 

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

func (*StmtResult_Row) Reset 

func (x *StmtResult_Row) Reset()

func (*StmtResult_Row) String 

func (x *StmtResult_Row) String() string

type StmtResult_Success 

type StmtResult_Success struct {
	Columns []*StmtResult_Column `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	Rows    []*StmtResult_Row    `protobuf:"bytes,2,rep,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

func (*StmtResult_Success) Descriptor deprecated 

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

Deprecated: Use StmtResult_Success.ProtoReflect.Descriptor instead.

func (*StmtResult_Success) GetColumns 

func (x *StmtResult_Success) GetColumns() []*StmtResult_Column

func (*StmtResult_Success) GetRows 

func (x *StmtResult_Success) GetRows() []*StmtResult_Row

func (*StmtResult_Success) ProtoMessage 

func (*StmtResult_Success) ProtoMessage()

func (*StmtResult_Success) ProtoReflect 

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

func (*StmtResult_Success) Reset 

func (x *StmtResult_Success) Reset()

func (*StmtResult_Success) String 

func (x *StmtResult_Success) String() string

type Update 

type Update struct{ Channel workflow.ReceiveChannel }

Errors fail the workflow by default

func (Update) Receive 

func (s Update) Receive(ctx workflow.Context) *UpdateRequest

Receive blocks until signal is received.

func (Update) ReceiveAsync 

func (s Update) ReceiveAsync() *UpdateRequest

ReceiveAsync returns received signal or nil if none.

func (Update) Select 

func (s Update) Select(sel workflow.Selector, fn func(*UpdateRequest)) workflow.Selector

Select adds the callback to the selector to be invoked when signal received. Callback can be nil.

type UpdateRequest 

type UpdateRequest struct {
	Request *StmtRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateRequest) Descriptor deprecated 

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

Deprecated: Use UpdateRequest.ProtoReflect.Descriptor instead.

func (*UpdateRequest) GetRequest 

func (x *UpdateRequest) GetRequest() *StmtRequest

func (*UpdateRequest) ProtoMessage 

func (*UpdateRequest) ProtoMessage()

func (*UpdateRequest) ProtoReflect 

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

func (*UpdateRequest) Reset 

func (x *UpdateRequest) Reset()

func (*UpdateRequest) String 

func (x *UpdateRequest) String() string

type Value 

type Value struct {

	// Types that are assignable to Value:
	//	*Value_NullValue
	//	*Value_IntValue
	//	*Value_FloatValue
	//	*Value_StringValue
	//	*Value_BytesValue
	Value isValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*Value) Descriptor deprecated 

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

Deprecated: Use Value.ProtoReflect.Descriptor instead.

func (*Value) GetBytesValue 

func (x *Value) GetBytesValue() []byte

func (*Value) GetFloatValue 

func (x *Value) GetFloatValue() float64

func (*Value) GetIntValue 

func (x *Value) GetIntValue() int64

func (*Value) GetNullValue 

func (x *Value) GetNullValue() bool

func (*Value) GetStringValue 

func (x *Value) GetStringValue() string

func (*Value) GetValue 

func (m *Value) GetValue() isValue_Value

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) ProtoReflect 

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

func (*Value) Reset 

func (x *Value) Reset()

func (*Value) String 

func (x *Value) String() string

type Value_BytesValue 

type Value_BytesValue struct {
	BytesValue []byte `protobuf:"bytes,5,opt,name=bytes_value,json=bytesValue,proto3,oneof"`
}

type Value_FloatValue 

type Value_FloatValue struct {
	FloatValue float64 `protobuf:"fixed64,3,opt,name=float_value,json=floatValue,proto3,oneof"`
}

type Value_IntValue 

type Value_IntValue struct {
	IntValue int64 `protobuf:"varint,2,opt,name=int_value,json=intValue,proto3,oneof"`
}

type Value_NullValue 

type Value_NullValue struct {
	NullValue bool `protobuf:"varint,1,opt,name=null_value,json=nullValue,proto3,oneof"`
}

type Value_StringValue 

type Value_StringValue struct {
	StringValue string `protobuf:"bytes,4,opt,name=string_value,json=stringValue,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.