core

package module
v0.0.6 Latest Latest
Warning

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

 Go to latest Published: Sep 6, 2025 License: MIT Imports: 11 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	CommonErrorCode_name = map[int32]string{
		0: "UNKNOWN",
		1: "INVALID_TYPE",
		2: "TIMEOUT",
		3: "NOT_FOUND",
		4: "BAD_REQUEST",
		5: "FORBIDDEN",
	}
	CommonErrorCode_value = map[string]int32{
		"UNKNOWN":      0,
		"INVALID_TYPE": 1,
		"TIMEOUT":      2,
		"NOT_FOUND":    3,
		"BAD_REQUEST":  4,
		"FORBIDDEN":    5,
	}
)

Enum value maps for CommonErrorCode.

View Source 
var (
	ExternalMessageType_name = map[int32]string{
		0:  "UNSPECIFIED",
		1:  "HAS_TOPIC_REQ",
		2:  "HAS_TOPIC_RESP",
		3:  "SUBSCRIBE_REQ",
		4:  "SUBSCRIBE_RESP",
		5:  "UNSUBSCRIBE_REQ",
		6:  "UNSUBSCRIBE_RESP",
		7:  "KV_SET_REQ",
		8:  "KV_SET_RESP",
		9:  "KV_GET_REQ",
		10: "KV_GET_RESP",
		11: "KV_LIST_REQ",
		12: "KV_LIST_RESP",
		13: "KV_DELETE_REQ",
		14: "KV_DELETE_RESP",
		15: "LOG_SEND_REQ",
		16: "LOG_SEND_RESP",
	}
	ExternalMessageType_value = map[string]int32{
		"UNSPECIFIED":      0,
		"HAS_TOPIC_REQ":    1,
		"HAS_TOPIC_RESP":   2,
		"SUBSCRIBE_REQ":    3,
		"SUBSCRIBE_RESP":   4,
		"UNSUBSCRIBE_REQ":  5,
		"UNSUBSCRIBE_RESP": 6,
		"KV_SET_REQ":       7,
		"KV_SET_RESP":      8,
		"KV_GET_REQ":       9,
		"KV_GET_RESP":      10,
		"KV_LIST_REQ":      11,
		"KV_LIST_RESP":     12,
		"KV_DELETE_REQ":    13,
		"KV_DELETE_RESP":   14,
		"LOG_SEND_REQ":     15,
		"LOG_SEND_RESP":    16,
	}
)

Enum value maps for ExternalMessageType.

View Source 
var (
	LogLevel_name = map[int32]string{
		0: "DEBUG",
		1: "INFO",
		2: "WARN",
		3: "ERROR",
	}
	LogLevel_value = map[string]int32{
		"DEBUG": 0,
		"INFO":  1,
		"WARN":  2,
		"ERROR": 3,
	}
)

Enum value maps for LogLevel.

Functions

func Exit added in v0.0.6 

func Exit(errorMsg string)

Exit requests that the host unsubscribe from all topics, eventually causing the plugin to be stopped and unloaded. If errorMsg is not empty, the status will be FAILED and errorMsg will be recorded in the log

func HasTopic added in v0.0.5 

func HasTopic(topic string, timeoutMS uint64) (bool, error)

HasTopic checks to see if anything is listening for the given topic

func KVDelete 

func KVDelete(key []byte) error

KVDelete deletes the value associated with the provided key. If there's no value with that key no error is returned.

func KVGet 

func KVGet(key []byte) ([]byte, error)

KVGet retrieves a value from the KV store. If no value with that key is present, akcore.ErrNotFound will be returned

func KVGetProto 

func KVGetProto(key []byte, p Unmarshaller) error

KVGetProto retrieves the value associated with key from the KV store and unmarshals it into p.

func KVSet 

func KVSet(key, value []byte) error

KVSet sets a value in the KV store with the specified key. If there's an existing value with that key it is overwritten

func KVSetProto 

func KVSetProto(key []byte, p Marshaller) error

KVSetProto marshals p and sets key to that value in the KV store.

func Log 

func Log(level LogLevel, message string, args ...any) error

Log a message on the host. If args are present there should be an even number of them. The even numbered args must be string keys. The odd numbered args must be an integer type, float type, string, or bool. It's slightly more convenient to use LogError(), LogInfo, etc

func LogBusError added in v0.0.5 

func LogBusError(msg string, err *Error) error

LogBusError logs a bus error's individual fields

func LogDebug 

func LogDebug(message string, args ...any) error

LogDebug logs a message at level DEBUG on the host. See the docs for Log() for a description of args

func LogError 

func LogError(message string, args ...any) error

LogError logs a message at level ERROR on the host. See the docs for Log() for a description of args

func LogInfo 

func LogInfo(message string, args ...any) error

LogInfo logs a message at level INFO on the host. See the docs for Log() for a description of args

func LogTrace deprecated added in v0.0.5 

func LogTrace(message string, args ...any) error

LogTrace is LogDebug but for messages you want to remove later

Deprecated: Not really, but I want the IDE to remind me to remove trace calls

func LogWarn 

func LogWarn(message string, args ...any) error

LogWarn logs a message at level WARN on the host. See the docs for Log() for a description of args

func MarshalArg 

func MarshalArg(msg *BusMessage) (pdk.Memory, error)

MarshalArg marshals the provided argument for passing as an argument to an invocation of a host function. You probably want to use Send, SendReply, or WaitForReply instead.

func MarshalMessage added in v0.0.2 

func MarshalMessage(msg *BusMessage, v Marshaller)

MarshalMessage marshals v to the Message field of msg. If marshalling fails an error is logged and msg.Error is set.

func ProtoMapJSON added in v0.0.5 

func ProtoMapJSON(m map[string]JSONMarshaller) ([]byte, error)

func Send 

func Send(msg *BusMessage) error

Send a BusMessage to the host

func SendReply 

func SendReply(msg *BusMessage) error

SendReply sends a BusMessage to the host that is a reply to a message received. The ReplyTo field should be set to the value from the received message.

func String added in v0.0.5 

func String(s string) *string

func Subscribe 

func Subscribe(topic string) error

Subscribe to a topic

func Unsubscribe 

func Unsubscribe(topic string) error

Unsubscribe from a topic. If no such subscription exists no error is returned.

func WaitForReplyWrap 

func WaitForReplyWrap[M any, REQ Marshaller, RESP UnmarshallerPTR[M]](
	msg *BusMessage, req REQ, process func(RESP, *Error), timeoutMS uint64,
) error

WaitForReplyWrap is a convenience function that marshals req, sends it via WaitForReply using msg, unmarshals the response into a RESP, and invokes process on the result. An error in marshalling req, unmarshalling the RESP, or in calling WaitForReply is returned directly. If the reply message from WaitForReply is non-nil, that is passed to process. The process function will receive a non-nil resp or non-nil *bus.Error, but not both.

Types

type BusMessage 

type BusMessage struct {
	Topic   string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Type    int32  `protobuf:"varint,2,opt,name=type,proto3" json:"type,omitempty"`
	Error   *Error `protobuf:"bytes,3,opt,name=error,proto3,oneof" json:"error,omitempty"`
	Message []byte `protobuf:"bytes,4,opt,name=message,proto3,oneof" json:"message,omitempty"`
	ReplyTo *int64 `protobuf:"varint,5,opt,name=reply_to,json=replyTo,proto3,oneof" json:"replyTo,omitempty"`
	FromMod string `protobuf:"bytes,6,opt,name=from_mod,json=fromMod,proto3" json:"fromMod,omitempty"`
	// contains filtered or unexported fields
}

func DefaultReply added in v0.0.2 

func DefaultReply(msg *BusMessage) *BusMessage

DefaultReply creates a template reply by copying msg's topic and incrementing the message's type

func UnmarshalReturn 

func UnmarshalReturn(offs uint64) (*BusMessage, error)

UnmarshalReturn unmarshals a message provided as the return value of the invocation of a host function. You probably want to use Send, SendReply, or WaitForReply instead.

func WaitForReply 

func WaitForReply(msg *BusMessage, timeoutMS uint64) (*BusMessage, error)

WaitForReply sends a message to the host and waits for a reply. If a is not received within timeoutMS milliseconds, the returned BusMessage.Error.Code will be CommonErrorCode_TIMEOUT.

func (*BusMessage) CloneMessageVT 

func (m *BusMessage) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*BusMessage) CloneVT 

func (m *BusMessage) CloneVT() *BusMessage

func (*BusMessage) EqualMessageVT 

func (this *BusMessage) EqualMessageVT(thatMsg any) bool

func (*BusMessage) EqualVT 

func (this *BusMessage) EqualVT(that *BusMessage) bool

func (*BusMessage) GetError 

func (x *BusMessage) GetError() *Error

func (*BusMessage) GetFromMod 

func (x *BusMessage) GetFromMod() string

func (*BusMessage) GetMessage 

func (x *BusMessage) GetMessage() []byte

func (*BusMessage) GetReplyTo 

func (x *BusMessage) GetReplyTo() int64

func (*BusMessage) GetTopic 

func (x *BusMessage) GetTopic() string

func (*BusMessage) GetType 

func (x *BusMessage) GetType() int32

func (*BusMessage) MarshalJSON added in v0.0.4 

func (x *BusMessage) MarshalJSON() ([]byte, error)

MarshalJSON marshals the BusMessage to JSON.

func (*BusMessage) MarshalProtoJSON added in v0.0.4 

func (x *BusMessage) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the BusMessage message to JSON.

func (*BusMessage) MarshalToSizedBufferVT 

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

func (*BusMessage) MarshalToVT 

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

func (*BusMessage) MarshalVT 

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

func (*BusMessage) ProtoMessage 

func (*BusMessage) ProtoMessage()

func (*BusMessage) Reset 

func (x *BusMessage) Reset()

func (*BusMessage) SizeVT 

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

func (*BusMessage) UnmarshalJSON added in v0.0.4 

func (x *BusMessage) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the BusMessage from JSON.

func (*BusMessage) UnmarshalProtoJSON added in v0.0.4 

func (x *BusMessage) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the BusMessage message from JSON.

func (*BusMessage) UnmarshalVT 

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

type CommonErrorCode 

type CommonErrorCode int32
const (
	CommonErrorCode_UNKNOWN      CommonErrorCode = 0
	CommonErrorCode_INVALID_TYPE CommonErrorCode = 1
	CommonErrorCode_TIMEOUT      CommonErrorCode = 2
	CommonErrorCode_NOT_FOUND    CommonErrorCode = 3
	CommonErrorCode_BAD_REQUEST  CommonErrorCode = 4
	CommonErrorCode_FORBIDDEN    CommonErrorCode = 5
)

func (CommonErrorCode) Enum 

func (x CommonErrorCode) Enum() *CommonErrorCode

func (CommonErrorCode) MarshalJSON added in v0.0.4 

func (x CommonErrorCode) MarshalJSON() ([]byte, error)

MarshalJSON marshals the CommonErrorCode to JSON.

func (CommonErrorCode) MarshalProtoJSON added in v0.0.4 

func (x CommonErrorCode) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the CommonErrorCode to JSON.

func (CommonErrorCode) MarshalText added in v0.0.4 

func (x CommonErrorCode) MarshalText() ([]byte, error)

MarshalText marshals the CommonErrorCode to text.

func (CommonErrorCode) String 

func (x CommonErrorCode) String() string

func (*CommonErrorCode) UnmarshalJSON added in v0.0.4 

func (x *CommonErrorCode) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the CommonErrorCode from JSON.

func (*CommonErrorCode) UnmarshalProtoJSON added in v0.0.4 

func (x *CommonErrorCode) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the CommonErrorCode from JSON.

func (*CommonErrorCode) UnmarshalText added in v0.0.4 

func (x *CommonErrorCode) UnmarshalText(b []byte) error

UnmarshalText unmarshals the CommonErrorCode from text.

type Error 

type Error struct {
	Code           int32   `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Detail         *string `protobuf:"bytes,2,opt,name=detail,proto3,oneof" json:"detail,omitempty"`
	UserMessage    *string `protobuf:"bytes,3,opt,name=user_message,json=userMessage,proto3,oneof" json:"userMessage,omitempty"`
	NotCommonError bool    `protobuf:"varint,4,opt,name=NotCommonError,proto3" json:"NotCommonError,omitempty"`
	// contains filtered or unexported fields
}

func BusError added in v0.0.5 

func BusError(err error) *Error

func InvalidTypeError added in v0.0.5 

func InvalidTypeError(err error) *Error

func NotFoundError added in v0.0.5 

func NotFoundError() *Error

func UnmarshalMessage added in v0.0.2 

func UnmarshalMessage(msg *BusMessage, v Unmarshaller) *Error

UnmarshalMessage unmarshals msg.Message to v. If unmarshalling fails an error is logged and an Error is returned.

func (*Error) CloneMessageVT 

func (m *Error) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*Error) CloneVT 

func (m *Error) CloneVT() *Error

func (*Error) EqualMessageVT 

func (this *Error) EqualMessageVT(thatMsg any) bool

func (*Error) EqualVT 

func (this *Error) EqualVT(that *Error) bool

func (*Error) Error 

func (e *Error) Error() string

Error implements the error interface.

func (*Error) GetCode 

func (x *Error) GetCode() int32

func (*Error) GetDetail 

func (x *Error) GetDetail() string

func (*Error) GetNotCommonError 

func (x *Error) GetNotCommonError() bool

func (*Error) GetUserMessage 

func (x *Error) GetUserMessage() string

func (*Error) MarshalJSON added in v0.0.4 

func (x *Error) MarshalJSON() ([]byte, error)

MarshalJSON marshals the Error to JSON.

func (*Error) MarshalProtoJSON added in v0.0.4 

func (x *Error) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the Error message to JSON.

func (*Error) MarshalToSizedBufferVT 

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

func (*Error) MarshalToVT 

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

func (*Error) MarshalVT 

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

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (x *Error) Reset()

func (*Error) SizeVT 

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

func (*Error) UnmarshalJSON added in v0.0.4 

func (x *Error) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the Error from JSON.

func (*Error) UnmarshalProtoJSON added in v0.0.4 

func (x *Error) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the Error message from JSON.

func (*Error) UnmarshalVT 

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

type ExternalMessageType 

type ExternalMessageType int32
const (
	ExternalMessageType_UNSPECIFIED      ExternalMessageType = 0
	ExternalMessageType_HAS_TOPIC_REQ    ExternalMessageType = 1
	ExternalMessageType_HAS_TOPIC_RESP   ExternalMessageType = 2
	ExternalMessageType_SUBSCRIBE_REQ    ExternalMessageType = 3
	ExternalMessageType_SUBSCRIBE_RESP   ExternalMessageType = 4
	ExternalMessageType_UNSUBSCRIBE_REQ  ExternalMessageType = 5
	ExternalMessageType_UNSUBSCRIBE_RESP ExternalMessageType = 6
	ExternalMessageType_KV_SET_REQ       ExternalMessageType = 7
	ExternalMessageType_KV_SET_RESP      ExternalMessageType = 8
	ExternalMessageType_KV_GET_REQ       ExternalMessageType = 9
	ExternalMessageType_KV_GET_RESP      ExternalMessageType = 10
	ExternalMessageType_KV_LIST_REQ      ExternalMessageType = 11
	ExternalMessageType_KV_LIST_RESP     ExternalMessageType = 12
	ExternalMessageType_KV_DELETE_REQ    ExternalMessageType = 13
	ExternalMessageType_KV_DELETE_RESP   ExternalMessageType = 14
	ExternalMessageType_LOG_SEND_REQ     ExternalMessageType = 15
	ExternalMessageType_LOG_SEND_RESP    ExternalMessageType = 16
)

func (ExternalMessageType) Enum 

func (x ExternalMessageType) Enum() *ExternalMessageType

func (ExternalMessageType) MarshalJSON added in v0.0.4 

func (x ExternalMessageType) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ExternalMessageType to JSON.

func (ExternalMessageType) MarshalProtoJSON added in v0.0.4 

func (x ExternalMessageType) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ExternalMessageType to JSON.

func (ExternalMessageType) MarshalText added in v0.0.4 

func (x ExternalMessageType) MarshalText() ([]byte, error)

MarshalText marshals the ExternalMessageType to text.

func (ExternalMessageType) String 

func (x ExternalMessageType) String() string

func (*ExternalMessageType) UnmarshalJSON added in v0.0.4 

func (x *ExternalMessageType) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ExternalMessageType from JSON.

func (*ExternalMessageType) UnmarshalProtoJSON added in v0.0.4 

func (x *ExternalMessageType) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ExternalMessageType from JSON.

func (*ExternalMessageType) UnmarshalText added in v0.0.4 

func (x *ExternalMessageType) UnmarshalText(b []byte) error

UnmarshalText unmarshals the ExternalMessageType from text.

type Handler added in v0.0.2 

type Handler func(*BusMessage) *BusMessage

A Handler handles bus messages, optionally returning a reply

type HasTopicRequest 

type HasTopicRequest struct {
	Topic     string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	TimeoutMs int32  `protobuf:"varint,2,opt,name=timeout_ms,json=timeoutMs,proto3" json:"timeoutMs,omitempty"`
	// contains filtered or unexported fields
}

func (*HasTopicRequest) CloneMessageVT 

func (m *HasTopicRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*HasTopicRequest) CloneVT 

func (m *HasTopicRequest) CloneVT() *HasTopicRequest

func (*HasTopicRequest) EqualMessageVT 

func (this *HasTopicRequest) EqualMessageVT(thatMsg any) bool

func (*HasTopicRequest) EqualVT 

func (this *HasTopicRequest) EqualVT(that *HasTopicRequest) bool

func (*HasTopicRequest) GetTimeoutMs 

func (x *HasTopicRequest) GetTimeoutMs() int32

func (*HasTopicRequest) GetTopic 

func (x *HasTopicRequest) GetTopic() string

func (*HasTopicRequest) MarshalJSON added in v0.0.4 

func (x *HasTopicRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the HasTopicRequest to JSON.

func (*HasTopicRequest) MarshalProtoJSON added in v0.0.4 

func (x *HasTopicRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the HasTopicRequest message to JSON.

func (*HasTopicRequest) MarshalToSizedBufferVT 

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

func (*HasTopicRequest) MarshalToVT 

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

func (*HasTopicRequest) MarshalVT 

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

func (*HasTopicRequest) ProtoMessage 

func (*HasTopicRequest) ProtoMessage()

func (*HasTopicRequest) Reset 

func (x *HasTopicRequest) Reset()

func (*HasTopicRequest) SizeVT 

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

func (*HasTopicRequest) UnmarshalJSON added in v0.0.4 

func (x *HasTopicRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the HasTopicRequest from JSON.

func (*HasTopicRequest) UnmarshalProtoJSON added in v0.0.4 

func (x *HasTopicRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the HasTopicRequest message from JSON.

func (*HasTopicRequest) UnmarshalVT 

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

type HasTopicResponse 

type HasTopicResponse struct {
	Topic    string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	HasTopic bool   `protobuf:"varint,2,opt,name=has_topic,json=hasTopic,proto3" json:"hasTopic,omitempty"`
	// contains filtered or unexported fields
}

func (*HasTopicResponse) CloneMessageVT 

func (m *HasTopicResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*HasTopicResponse) CloneVT 

func (m *HasTopicResponse) CloneVT() *HasTopicResponse

func (*HasTopicResponse) EqualMessageVT 

func (this *HasTopicResponse) EqualMessageVT(thatMsg any) bool

func (*HasTopicResponse) EqualVT 

func (this *HasTopicResponse) EqualVT(that *HasTopicResponse) bool

func (*HasTopicResponse) GetHasTopic 

func (x *HasTopicResponse) GetHasTopic() bool

func (*HasTopicResponse) GetTopic 

func (x *HasTopicResponse) GetTopic() string

func (*HasTopicResponse) MarshalJSON added in v0.0.4 

func (x *HasTopicResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the HasTopicResponse to JSON.

func (*HasTopicResponse) MarshalProtoJSON added in v0.0.4 

func (x *HasTopicResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the HasTopicResponse message to JSON.

func (*HasTopicResponse) MarshalToSizedBufferVT 

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

func (*HasTopicResponse) MarshalToVT 

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

func (*HasTopicResponse) MarshalVT 

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

func (*HasTopicResponse) ProtoMessage 

func (*HasTopicResponse) ProtoMessage()

func (*HasTopicResponse) Reset 

func (x *HasTopicResponse) Reset()

func (*HasTopicResponse) SizeVT 

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

func (*HasTopicResponse) UnmarshalJSON added in v0.0.4 

func (x *HasTopicResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the HasTopicResponse from JSON.

func (*HasTopicResponse) UnmarshalProtoJSON added in v0.0.4 

func (x *HasTopicResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the HasTopicResponse message from JSON.

func (*HasTopicResponse) UnmarshalVT 

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

type JSONMap added in v0.0.5 

type JSONMap map[string]JSONMarshaller

func (JSONMap) MarshalJSON added in v0.0.5 

func (m JSONMap) MarshalJSON() ([]byte, error)

type JSONMarshaller added in v0.0.5 

type JSONMarshaller interface {
	MarshalJSON() ([]byte, error)
}

type JSONString added in v0.0.5 

type JSONString string

func (JSONString) MarshalJSON added in v0.0.5 

func (s JSONString) MarshalJSON() ([]byte, error)

type KVDeleteRequest 

type KVDeleteRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*KVDeleteRequest) CloneMessageVT 

func (m *KVDeleteRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*KVDeleteRequest) CloneVT 

func (m *KVDeleteRequest) CloneVT() *KVDeleteRequest

func (*KVDeleteRequest) EqualMessageVT 

func (this *KVDeleteRequest) EqualMessageVT(thatMsg any) bool

func (*KVDeleteRequest) EqualVT 

func (this *KVDeleteRequest) EqualVT(that *KVDeleteRequest) bool

func (*KVDeleteRequest) GetKey 

func (x *KVDeleteRequest) GetKey() []byte

func (*KVDeleteRequest) MarshalJSON added in v0.0.4 

func (x *KVDeleteRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the KVDeleteRequest to JSON.

func (*KVDeleteRequest) MarshalProtoJSON added in v0.0.4 

func (x *KVDeleteRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the KVDeleteRequest message to JSON.

func (*KVDeleteRequest) MarshalToSizedBufferVT 

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

func (*KVDeleteRequest) MarshalToVT 

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

func (*KVDeleteRequest) MarshalVT 

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

func (*KVDeleteRequest) ProtoMessage 

func (*KVDeleteRequest) ProtoMessage()

func (*KVDeleteRequest) Reset 

func (x *KVDeleteRequest) Reset()

func (*KVDeleteRequest) SizeVT 

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

func (*KVDeleteRequest) UnmarshalJSON added in v0.0.4 

func (x *KVDeleteRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the KVDeleteRequest from JSON.

func (*KVDeleteRequest) UnmarshalProtoJSON added in v0.0.4 

func (x *KVDeleteRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the KVDeleteRequest message from JSON.

func (*KVDeleteRequest) UnmarshalVT 

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

type KVDeleteResponse 

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

func (*KVDeleteResponse) CloneMessageVT 

func (m *KVDeleteResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*KVDeleteResponse) CloneVT 

func (m *KVDeleteResponse) CloneVT() *KVDeleteResponse

func (*KVDeleteResponse) EqualMessageVT 

func (this *KVDeleteResponse) EqualMessageVT(thatMsg any) bool

func (*KVDeleteResponse) EqualVT 

func (this *KVDeleteResponse) EqualVT(that *KVDeleteResponse) bool

func (*KVDeleteResponse) MarshalJSON added in v0.0.4 

func (x *KVDeleteResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the KVDeleteResponse to JSON.

func (*KVDeleteResponse) MarshalProtoJSON added in v0.0.4 

func (x *KVDeleteResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the KVDeleteResponse message to JSON.

func (*KVDeleteResponse) MarshalToSizedBufferVT 

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

func (*KVDeleteResponse) MarshalToVT 

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

func (*KVDeleteResponse) MarshalVT 

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

func (*KVDeleteResponse) ProtoMessage 

func (*KVDeleteResponse) ProtoMessage()

func (*KVDeleteResponse) Reset 

func (x *KVDeleteResponse) Reset()

func (*KVDeleteResponse) SizeVT 

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

func (*KVDeleteResponse) UnmarshalJSON added in v0.0.4 

func (x *KVDeleteResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the KVDeleteResponse from JSON.

func (*KVDeleteResponse) UnmarshalProtoJSON added in v0.0.4 

func (x *KVDeleteResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the KVDeleteResponse message from JSON.

func (*KVDeleteResponse) UnmarshalVT 

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

type KVGetRequest 

type KVGetRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*KVGetRequest) CloneMessageVT 

func (m *KVGetRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*KVGetRequest) CloneVT 

func (m *KVGetRequest) CloneVT() *KVGetRequest

func (*KVGetRequest) EqualMessageVT 

func (this *KVGetRequest) EqualMessageVT(thatMsg any) bool

func (*KVGetRequest) EqualVT 

func (this *KVGetRequest) EqualVT(that *KVGetRequest) bool

func (*KVGetRequest) GetKey 

func (x *KVGetRequest) GetKey() []byte

func (*KVGetRequest) MarshalJSON added in v0.0.4 

func (x *KVGetRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the KVGetRequest to JSON.

func (*KVGetRequest) MarshalProtoJSON added in v0.0.4 

func (x *KVGetRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the KVGetRequest message to JSON.

func (*KVGetRequest) MarshalToSizedBufferVT 

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

func (*KVGetRequest) MarshalToVT 

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

func (*KVGetRequest) MarshalVT 

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

func (*KVGetRequest) ProtoMessage 

func (*KVGetRequest) ProtoMessage()

func (*KVGetRequest) Reset 

func (x *KVGetRequest) Reset()

func (*KVGetRequest) SizeVT 

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

func (*KVGetRequest) UnmarshalJSON added in v0.0.4 

func (x *KVGetRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the KVGetRequest from JSON.

func (*KVGetRequest) UnmarshalProtoJSON added in v0.0.4 

func (x *KVGetRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the KVGetRequest message from JSON.

func (*KVGetRequest) UnmarshalVT 

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

type KVGetResponse 

type KVGetResponse struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*KVGetResponse) CloneMessageVT 

func (m *KVGetResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*KVGetResponse) CloneVT 

func (m *KVGetResponse) CloneVT() *KVGetResponse

func (*KVGetResponse) EqualMessageVT 

func (this *KVGetResponse) EqualMessageVT(thatMsg any) bool

func (*KVGetResponse) EqualVT 

func (this *KVGetResponse) EqualVT(that *KVGetResponse) bool

func (*KVGetResponse) GetKey 

func (x *KVGetResponse) GetKey() []byte

func (*KVGetResponse) GetValue 

func (x *KVGetResponse) GetValue() []byte

func (*KVGetResponse) MarshalJSON added in v0.0.4 

func (x *KVGetResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the KVGetResponse to JSON.

func (*KVGetResponse) MarshalProtoJSON added in v0.0.4 

func (x *KVGetResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the KVGetResponse message to JSON.

func (*KVGetResponse) MarshalToSizedBufferVT 

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

func (*KVGetResponse) MarshalToVT 

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

func (*KVGetResponse) MarshalVT 

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

func (*KVGetResponse) ProtoMessage 

func (*KVGetResponse) ProtoMessage()

func (*KVGetResponse) Reset 

func (x *KVGetResponse) Reset()

func (*KVGetResponse) SizeVT 

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

func (*KVGetResponse) UnmarshalJSON added in v0.0.4 

func (x *KVGetResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the KVGetResponse from JSON.

func (*KVGetResponse) UnmarshalProtoJSON added in v0.0.4 

func (x *KVGetResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the KVGetResponse message from JSON.

func (*KVGetResponse) UnmarshalVT 

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

type KVListRequest 

type KVListRequest struct {
	Prefix []byte `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Offset uint32 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Limit  uint32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*KVListRequest) CloneMessageVT 

func (m *KVListRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*KVListRequest) CloneVT 

func (m *KVListRequest) CloneVT() *KVListRequest

func (*KVListRequest) EqualMessageVT 

func (this *KVListRequest) EqualMessageVT(thatMsg any) bool

func (*KVListRequest) EqualVT 

func (this *KVListRequest) EqualVT(that *KVListRequest) bool

func (*KVListRequest) GetLimit 

func (x *KVListRequest) GetLimit() uint32

func (*KVListRequest) GetOffset 

func (x *KVListRequest) GetOffset() uint32

func (*KVListRequest) GetPrefix 

func (x *KVListRequest) GetPrefix() []byte

func (*KVListRequest) MarshalJSON added in v0.0.4 

func (x *KVListRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the KVListRequest to JSON.

func (*KVListRequest) MarshalProtoJSON added in v0.0.4 

func (x *KVListRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the KVListRequest message to JSON.

func (*KVListRequest) MarshalToSizedBufferVT 

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

func (*KVListRequest) MarshalToVT 

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

func (*KVListRequest) MarshalVT 

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

func (*KVListRequest) ProtoMessage 

func (*KVListRequest) ProtoMessage()

func (*KVListRequest) Reset 

func (x *KVListRequest) Reset()

func (*KVListRequest) SizeVT 

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

func (*KVListRequest) UnmarshalJSON added in v0.0.4 

func (x *KVListRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the KVListRequest from JSON.

func (*KVListRequest) UnmarshalProtoJSON added in v0.0.4 

func (x *KVListRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the KVListRequest message from JSON.

func (*KVListRequest) UnmarshalVT 

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

type KVListResponse 

type KVListResponse struct {
	Keys         [][]byte `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	Prefix       []byte   `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"`
	TotalMatches uint32   `protobuf:"varint,3,opt,name=total_matches,json=totalMatches,proto3" json:"totalMatches,omitempty"`
	Offset       uint32   `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"`
	Limit        uint32   `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func KVList 

func KVList(prefix []byte, limit, offset int) (*KVListResponse, error)

KVList lists keys matching a given prefix or all values if prefix is nil. The limit parameter limits the number of matching keys returned. If limit is 0, all matches are returned. The offset parameter can be used to skip matches. If offset is greater than or equal to the total number of matches, no matches are returned. Pagination can be implemented by using the same limit in successive calls and specifying the offset to be the total number of matches retrieved until it reaches the total number of matches.

func (*KVListResponse) CloneMessageVT 

func (m *KVListResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*KVListResponse) CloneVT 

func (m *KVListResponse) CloneVT() *KVListResponse

func (*KVListResponse) EqualMessageVT 

func (this *KVListResponse) EqualMessageVT(thatMsg any) bool

func (*KVListResponse) EqualVT 

func (this *KVListResponse) EqualVT(that *KVListResponse) bool

func (*KVListResponse) GetKeys 

func (x *KVListResponse) GetKeys() [][]byte

func (*KVListResponse) GetLimit 

func (x *KVListResponse) GetLimit() uint32

func (*KVListResponse) GetOffset 

func (x *KVListResponse) GetOffset() uint32

func (*KVListResponse) GetPrefix 

func (x *KVListResponse) GetPrefix() []byte

func (*KVListResponse) GetTotalMatches 

func (x *KVListResponse) GetTotalMatches() uint32

func (*KVListResponse) MarshalJSON added in v0.0.4 

func (x *KVListResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the KVListResponse to JSON.

func (*KVListResponse) MarshalProtoJSON added in v0.0.4 

func (x *KVListResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the KVListResponse message to JSON.

func (*KVListResponse) MarshalToSizedBufferVT 

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

func (*KVListResponse) MarshalToVT 

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

func (*KVListResponse) MarshalVT 

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

func (*KVListResponse) ProtoMessage 

func (*KVListResponse) ProtoMessage()

func (*KVListResponse) Reset 

func (x *KVListResponse) Reset()

func (*KVListResponse) SizeVT 

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

func (*KVListResponse) UnmarshalJSON added in v0.0.4 

func (x *KVListResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the KVListResponse from JSON.

func (*KVListResponse) UnmarshalProtoJSON added in v0.0.4 

func (x *KVListResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the KVListResponse message from JSON.

func (*KVListResponse) UnmarshalVT 

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

type KVSetRequest 

type KVSetRequest struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*KVSetRequest) CloneMessageVT 

func (m *KVSetRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*KVSetRequest) CloneVT 

func (m *KVSetRequest) CloneVT() *KVSetRequest

func (*KVSetRequest) EqualMessageVT 

func (this *KVSetRequest) EqualMessageVT(thatMsg any) bool

func (*KVSetRequest) EqualVT 

func (this *KVSetRequest) EqualVT(that *KVSetRequest) bool

func (*KVSetRequest) GetKey 

func (x *KVSetRequest) GetKey() []byte

func (*KVSetRequest) GetValue 

func (x *KVSetRequest) GetValue() []byte

func (*KVSetRequest) MarshalJSON added in v0.0.4 

func (x *KVSetRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the KVSetRequest to JSON.

func (*KVSetRequest) MarshalProtoJSON added in v0.0.4 

func (x *KVSetRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the KVSetRequest message to JSON.

func (*KVSetRequest) MarshalToSizedBufferVT 

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

func (*KVSetRequest) MarshalToVT 

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

func (*KVSetRequest) MarshalVT 

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

func (*KVSetRequest) ProtoMessage 

func (*KVSetRequest) ProtoMessage()

func (*KVSetRequest) Reset 

func (x *KVSetRequest) Reset()

func (*KVSetRequest) SizeVT 

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

func (*KVSetRequest) UnmarshalJSON added in v0.0.4 

func (x *KVSetRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the KVSetRequest from JSON.

func (*KVSetRequest) UnmarshalProtoJSON added in v0.0.4 

func (x *KVSetRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the KVSetRequest message from JSON.

func (*KVSetRequest) UnmarshalVT 

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

type KVSetResponse 

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

func (*KVSetResponse) CloneMessageVT 

func (m *KVSetResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*KVSetResponse) CloneVT 

func (m *KVSetResponse) CloneVT() *KVSetResponse

func (*KVSetResponse) EqualMessageVT 

func (this *KVSetResponse) EqualMessageVT(thatMsg any) bool

func (*KVSetResponse) EqualVT 

func (this *KVSetResponse) EqualVT(that *KVSetResponse) bool

func (*KVSetResponse) MarshalJSON added in v0.0.4 

func (x *KVSetResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the KVSetResponse to JSON.

func (*KVSetResponse) MarshalProtoJSON added in v0.0.4 

func (x *KVSetResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the KVSetResponse message to JSON.

func (*KVSetResponse) MarshalToSizedBufferVT 

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

func (*KVSetResponse) MarshalToVT 

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

func (*KVSetResponse) MarshalVT 

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

func (*KVSetResponse) ProtoMessage 

func (*KVSetResponse) ProtoMessage()

func (*KVSetResponse) Reset 

func (x *KVSetResponse) Reset()

func (*KVSetResponse) SizeVT 

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

func (*KVSetResponse) UnmarshalJSON added in v0.0.4 

func (x *KVSetResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the KVSetResponse from JSON.

func (*KVSetResponse) UnmarshalProtoJSON added in v0.0.4 

func (x *KVSetResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the KVSetResponse message from JSON.

func (*KVSetResponse) UnmarshalVT 

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

type LogLevel 

type LogLevel int32
const (
	LogLevel_DEBUG LogLevel = 0
	LogLevel_INFO  LogLevel = 1
	LogLevel_WARN  LogLevel = 2
	LogLevel_ERROR LogLevel = 3
)

func (LogLevel) Enum 

func (x LogLevel) Enum() *LogLevel

func (LogLevel) MarshalJSON added in v0.0.4 

func (x LogLevel) MarshalJSON() ([]byte, error)

MarshalJSON marshals the LogLevel to JSON.

func (LogLevel) MarshalProtoJSON added in v0.0.4 

func (x LogLevel) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the LogLevel to JSON.

func (LogLevel) MarshalText added in v0.0.4 

func (x LogLevel) MarshalText() ([]byte, error)

MarshalText marshals the LogLevel to text.

func (LogLevel) String 

func (x LogLevel) String() string

func (*LogLevel) UnmarshalJSON added in v0.0.4 

func (x *LogLevel) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the LogLevel from JSON.

func (*LogLevel) UnmarshalProtoJSON added in v0.0.4 

func (x *LogLevel) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the LogLevel from JSON.

func (*LogLevel) UnmarshalText added in v0.0.4 

func (x *LogLevel) UnmarshalText(b []byte) error

UnmarshalText unmarshals the LogLevel from text.

type LogSendRequest 

type LogSendRequest struct {
	Level   LogLevel              `protobuf:"varint,1,opt,name=level,proto3" json:"level,omitempty"`
	Message string                `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Args    []*LogSendRequest_Arg `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

func (*LogSendRequest) CloneMessageVT 

func (m *LogSendRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*LogSendRequest) CloneVT 

func (m *LogSendRequest) CloneVT() *LogSendRequest

func (*LogSendRequest) EqualMessageVT 

func (this *LogSendRequest) EqualMessageVT(thatMsg any) bool

func (*LogSendRequest) EqualVT 

func (this *LogSendRequest) EqualVT(that *LogSendRequest) bool

func (*LogSendRequest) GetArgs 

func (x *LogSendRequest) GetArgs() []*LogSendRequest_Arg

func (*LogSendRequest) GetLevel 

func (x *LogSendRequest) GetLevel() LogLevel

func (*LogSendRequest) GetMessage 

func (x *LogSendRequest) GetMessage() string

func (*LogSendRequest) MarshalJSON added in v0.0.4 

func (x *LogSendRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the LogSendRequest to JSON.

func (*LogSendRequest) MarshalProtoJSON added in v0.0.4 

func (x *LogSendRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the LogSendRequest message to JSON.

func (*LogSendRequest) MarshalToSizedBufferVT 

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

func (*LogSendRequest) MarshalToVT 

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

func (*LogSendRequest) MarshalVT 

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

func (*LogSendRequest) ProtoMessage 

func (*LogSendRequest) ProtoMessage()

func (*LogSendRequest) Reset 

func (x *LogSendRequest) Reset()

func (*LogSendRequest) SizeVT 

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

func (*LogSendRequest) UnmarshalJSON added in v0.0.4 

func (x *LogSendRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the LogSendRequest from JSON.

func (*LogSendRequest) UnmarshalProtoJSON added in v0.0.4 

func (x *LogSendRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the LogSendRequest message from JSON.

func (*LogSendRequest) UnmarshalVT 

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

type LogSendRequest_Arg 

type LogSendRequest_Arg struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Types that are assignable to Value:
	//
	//	*LogSendRequest_Arg_String_
	//	*LogSendRequest_Arg_Bool
	//	*LogSendRequest_Arg_Int64
	//	*LogSendRequest_Arg_Double
	Value isLogSendRequest_Arg_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*LogSendRequest_Arg) CloneMessageVT 

func (m *LogSendRequest_Arg) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*LogSendRequest_Arg) CloneVT 

func (m *LogSendRequest_Arg) CloneVT() *LogSendRequest_Arg

func (*LogSendRequest_Arg) EqualMessageVT 

func (this *LogSendRequest_Arg) EqualMessageVT(thatMsg any) bool

func (*LogSendRequest_Arg) EqualVT 

func (this *LogSendRequest_Arg) EqualVT(that *LogSendRequest_Arg) bool

func (*LogSendRequest_Arg) GetBool 

func (x *LogSendRequest_Arg) GetBool() bool

func (*LogSendRequest_Arg) GetDouble 

func (x *LogSendRequest_Arg) GetDouble() float64

func (*LogSendRequest_Arg) GetInt64 

func (x *LogSendRequest_Arg) GetInt64() int64

func (*LogSendRequest_Arg) GetKey 

func (x *LogSendRequest_Arg) GetKey() string

func (*LogSendRequest_Arg) GetString_ 

func (x *LogSendRequest_Arg) GetString_() string

func (*LogSendRequest_Arg) GetValue 

func (m *LogSendRequest_Arg) GetValue() isLogSendRequest_Arg_Value

func (*LogSendRequest_Arg) MarshalJSON added in v0.0.4 

func (x *LogSendRequest_Arg) MarshalJSON() ([]byte, error)

MarshalJSON marshals the LogSendRequest_Arg to JSON.

func (*LogSendRequest_Arg) MarshalProtoJSON added in v0.0.4 

func (x *LogSendRequest_Arg) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the LogSendRequest_Arg message to JSON.

func (*LogSendRequest_Arg) MarshalToSizedBufferVT 

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

func (*LogSendRequest_Arg) MarshalToVT 

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

func (*LogSendRequest_Arg) MarshalVT 

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

func (*LogSendRequest_Arg) ProtoMessage 

func (*LogSendRequest_Arg) ProtoMessage()

func (*LogSendRequest_Arg) Reset 

func (x *LogSendRequest_Arg) Reset()

func (*LogSendRequest_Arg) SizeVT 

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

func (*LogSendRequest_Arg) UnmarshalJSON added in v0.0.4 

func (x *LogSendRequest_Arg) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the LogSendRequest_Arg from JSON.

func (*LogSendRequest_Arg) UnmarshalProtoJSON added in v0.0.4 

func (x *LogSendRequest_Arg) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the LogSendRequest_Arg message from JSON.

func (*LogSendRequest_Arg) UnmarshalVT 

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

type LogSendRequest_Arg_Bool 

type LogSendRequest_Arg_Bool struct {
	Bool bool `protobuf:"varint,3,opt,name=bool,proto3,oneof"`
}

func (*LogSendRequest_Arg_Bool) CloneOneofVT 

func (m *LogSendRequest_Arg_Bool) CloneOneofVT() isLogSendRequest_Arg_Value

func (*LogSendRequest_Arg_Bool) CloneVT 

func (m *LogSendRequest_Arg_Bool) CloneVT() *LogSendRequest_Arg_Bool

func (*LogSendRequest_Arg_Bool) EqualVT 

func (this *LogSendRequest_Arg_Bool) EqualVT(thatIface isLogSendRequest_Arg_Value) bool

func (*LogSendRequest_Arg_Bool) MarshalToSizedBufferVT 

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

func (*LogSendRequest_Arg_Bool) MarshalToVT 

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

func (*LogSendRequest_Arg_Bool) SizeVT 

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

type LogSendRequest_Arg_Double 

type LogSendRequest_Arg_Double struct {
	Double float64 `protobuf:"fixed64,5,opt,name=double,proto3,oneof"`
}

func (*LogSendRequest_Arg_Double) CloneOneofVT 

func (m *LogSendRequest_Arg_Double) CloneOneofVT() isLogSendRequest_Arg_Value

func (*LogSendRequest_Arg_Double) CloneVT 

func (m *LogSendRequest_Arg_Double) CloneVT() *LogSendRequest_Arg_Double

func (*LogSendRequest_Arg_Double) EqualVT 

func (this *LogSendRequest_Arg_Double) EqualVT(thatIface isLogSendRequest_Arg_Value) bool

func (*LogSendRequest_Arg_Double) MarshalToSizedBufferVT 

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

func (*LogSendRequest_Arg_Double) MarshalToVT 

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

func (*LogSendRequest_Arg_Double) SizeVT 

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

type LogSendRequest_Arg_Int64 

type LogSendRequest_Arg_Int64 struct {
	Int64 int64 `protobuf:"varint,4,opt,name=int64,proto3,oneof"`
}

func (*LogSendRequest_Arg_Int64) CloneOneofVT 

func (m *LogSendRequest_Arg_Int64) CloneOneofVT() isLogSendRequest_Arg_Value

func (*LogSendRequest_Arg_Int64) CloneVT 

func (m *LogSendRequest_Arg_Int64) CloneVT() *LogSendRequest_Arg_Int64

func (*LogSendRequest_Arg_Int64) EqualVT 

func (this *LogSendRequest_Arg_Int64) EqualVT(thatIface isLogSendRequest_Arg_Value) bool

func (*LogSendRequest_Arg_Int64) MarshalToSizedBufferVT 

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

func (*LogSendRequest_Arg_Int64) MarshalToVT 

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

func (*LogSendRequest_Arg_Int64) SizeVT 

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

type LogSendRequest_Arg_String_ 

type LogSendRequest_Arg_String_ struct {
	String_ string `protobuf:"bytes,2,opt,name=string,proto3,oneof"`
}

func (*LogSendRequest_Arg_String_) CloneOneofVT 

func (m *LogSendRequest_Arg_String_) CloneOneofVT() isLogSendRequest_Arg_Value

func (*LogSendRequest_Arg_String_) CloneVT 

func (m *LogSendRequest_Arg_String_) CloneVT() *LogSendRequest_Arg_String_

func (*LogSendRequest_Arg_String_) EqualVT 

func (this *LogSendRequest_Arg_String_) EqualVT(thatIface isLogSendRequest_Arg_Value) bool

func (*LogSendRequest_Arg_String_) MarshalToSizedBufferVT 

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

func (*LogSendRequest_Arg_String_) MarshalToVT 

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

func (*LogSendRequest_Arg_String_) SizeVT 

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

type LogSendResponse 

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

func (*LogSendResponse) CloneMessageVT 

func (m *LogSendResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*LogSendResponse) CloneVT 

func (m *LogSendResponse) CloneVT() *LogSendResponse

func (*LogSendResponse) EqualMessageVT 

func (this *LogSendResponse) EqualMessageVT(thatMsg any) bool

func (*LogSendResponse) EqualVT 

func (this *LogSendResponse) EqualVT(that *LogSendResponse) bool

func (*LogSendResponse) MarshalJSON added in v0.0.4 

func (x *LogSendResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the LogSendResponse to JSON.

func (*LogSendResponse) MarshalProtoJSON added in v0.0.4 

func (x *LogSendResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the LogSendResponse message to JSON.

func (*LogSendResponse) MarshalToSizedBufferVT 

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

func (*LogSendResponse) MarshalToVT 

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

func (*LogSendResponse) MarshalVT 

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

func (*LogSendResponse) ProtoMessage 

func (*LogSendResponse) ProtoMessage()

func (*LogSendResponse) Reset 

func (x *LogSendResponse) Reset()

func (*LogSendResponse) SizeVT 

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

func (*LogSendResponse) UnmarshalJSON added in v0.0.4 

func (x *LogSendResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the LogSendResponse from JSON.

func (*LogSendResponse) UnmarshalProtoJSON added in v0.0.4 

func (x *LogSendResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the LogSendResponse message from JSON.

func (*LogSendResponse) UnmarshalVT 

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

type Marshaller 

type Marshaller interface {
	MarshalVT() ([]byte, error)
}

Marshaller represents a proto that can be marshalled, suitable for tinygo.

type SubscribeRequest 

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

func (*SubscribeRequest) CloneMessageVT 

func (m *SubscribeRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*SubscribeRequest) CloneVT 

func (m *SubscribeRequest) CloneVT() *SubscribeRequest

func (*SubscribeRequest) EqualMessageVT 

func (this *SubscribeRequest) EqualMessageVT(thatMsg any) bool

func (*SubscribeRequest) EqualVT 

func (this *SubscribeRequest) EqualVT(that *SubscribeRequest) bool

func (*SubscribeRequest) GetTopic 

func (x *SubscribeRequest) GetTopic() string

func (*SubscribeRequest) MarshalJSON added in v0.0.4 

func (x *SubscribeRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the SubscribeRequest to JSON.

func (*SubscribeRequest) MarshalProtoJSON added in v0.0.4 

func (x *SubscribeRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the SubscribeRequest message to JSON.

func (*SubscribeRequest) MarshalToSizedBufferVT 

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

func (*SubscribeRequest) MarshalToVT 

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

func (*SubscribeRequest) MarshalVT 

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

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) Reset 

func (x *SubscribeRequest) Reset()

func (*SubscribeRequest) SizeVT 

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

func (*SubscribeRequest) UnmarshalJSON added in v0.0.4 

func (x *SubscribeRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the SubscribeRequest from JSON.

func (*SubscribeRequest) UnmarshalProtoJSON added in v0.0.4 

func (x *SubscribeRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the SubscribeRequest message from JSON.

func (*SubscribeRequest) UnmarshalVT 

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

type SubscribeResponse 

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

func (*SubscribeResponse) CloneMessageVT 

func (m *SubscribeResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*SubscribeResponse) CloneVT 

func (m *SubscribeResponse) CloneVT() *SubscribeResponse

func (*SubscribeResponse) EqualMessageVT 

func (this *SubscribeResponse) EqualMessageVT(thatMsg any) bool

func (*SubscribeResponse) EqualVT 

func (this *SubscribeResponse) EqualVT(that *SubscribeResponse) bool

func (*SubscribeResponse) MarshalJSON added in v0.0.4 

func (x *SubscribeResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the SubscribeResponse to JSON.

func (*SubscribeResponse) MarshalProtoJSON added in v0.0.4 

func (x *SubscribeResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the SubscribeResponse message to JSON.

func (*SubscribeResponse) MarshalToSizedBufferVT 

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

func (*SubscribeResponse) MarshalToVT 

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

func (*SubscribeResponse) MarshalVT 

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

func (*SubscribeResponse) ProtoMessage 

func (*SubscribeResponse) ProtoMessage()

func (*SubscribeResponse) Reset 

func (x *SubscribeResponse) Reset()

func (*SubscribeResponse) SizeVT 

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

func (*SubscribeResponse) UnmarshalJSON added in v0.0.4 

func (x *SubscribeResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the SubscribeResponse from JSON.

func (*SubscribeResponse) UnmarshalProtoJSON added in v0.0.4 

func (x *SubscribeResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the SubscribeResponse message from JSON.

func (*SubscribeResponse) UnmarshalVT 

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

type TopicRouter added in v0.0.2 

type TopicRouter map[string]TypeRouter

A TopicRouter dispatches a message to the appropriate TypeHandler by topic.

func (TopicRouter) Handle added in v0.0.2 

func (r TopicRouter) Handle(msg *BusMessage)

Handle a message using the TypeHandler for the type. If there's no handler for the topic no action is taken.

type TypeRouter added in v0.0.2 

type TypeRouter map[int32]Handler

TypeRouter dispatches a message to its respective handler by message type

func (TypeRouter) Handle added in v0.0.2 

func (r TypeRouter) Handle(msg *BusMessage) *BusMessage

Handle a message based on type. If there's no handler for the type no action is taken

type Unmarshaller 

type Unmarshaller interface {
	UnmarshalVT([]byte) error
}

Unmarshaller represents a proto that can be unmarshalled, suitable for tinygo.

type UnmarshallerPTR 

type UnmarshallerPTR[M any] interface {
	*M
	Unmarshaller
}

UnmarshallerPTR represents a value type where a pointer to that value implements Unmarshaller

type UnsubscribeRequest 

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

func (*UnsubscribeRequest) CloneMessageVT 

func (m *UnsubscribeRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*UnsubscribeRequest) CloneVT 

func (m *UnsubscribeRequest) CloneVT() *UnsubscribeRequest

func (*UnsubscribeRequest) EqualMessageVT 

func (this *UnsubscribeRequest) EqualMessageVT(thatMsg any) bool

func (*UnsubscribeRequest) EqualVT 

func (this *UnsubscribeRequest) EqualVT(that *UnsubscribeRequest) bool

func (*UnsubscribeRequest) GetTopic 

func (x *UnsubscribeRequest) GetTopic() string

func (*UnsubscribeRequest) MarshalJSON added in v0.0.4 

func (x *UnsubscribeRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the UnsubscribeRequest to JSON.

func (*UnsubscribeRequest) MarshalProtoJSON added in v0.0.4 

func (x *UnsubscribeRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the UnsubscribeRequest message to JSON.

func (*UnsubscribeRequest) MarshalToSizedBufferVT 

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

func (*UnsubscribeRequest) MarshalToVT 

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

func (*UnsubscribeRequest) MarshalVT 

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

func (*UnsubscribeRequest) ProtoMessage 

func (*UnsubscribeRequest) ProtoMessage()

func (*UnsubscribeRequest) Reset 

func (x *UnsubscribeRequest) Reset()

func (*UnsubscribeRequest) SizeVT 

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

func (*UnsubscribeRequest) UnmarshalJSON added in v0.0.4 

func (x *UnsubscribeRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the UnsubscribeRequest from JSON.

func (*UnsubscribeRequest) UnmarshalProtoJSON added in v0.0.4 

func (x *UnsubscribeRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the UnsubscribeRequest message from JSON.

func (*UnsubscribeRequest) UnmarshalVT 

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

type UnsubscribeResponse 

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

func (*UnsubscribeResponse) CloneMessageVT 

func (m *UnsubscribeResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*UnsubscribeResponse) CloneVT 

func (m *UnsubscribeResponse) CloneVT() *UnsubscribeResponse

func (*UnsubscribeResponse) EqualMessageVT 

func (this *UnsubscribeResponse) EqualMessageVT(thatMsg any) bool

func (*UnsubscribeResponse) EqualVT 

func (this *UnsubscribeResponse) EqualVT(that *UnsubscribeResponse) bool

func (*UnsubscribeResponse) MarshalJSON added in v0.0.4 

func (x *UnsubscribeResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the UnsubscribeResponse to JSON.

func (*UnsubscribeResponse) MarshalProtoJSON added in v0.0.4 

func (x *UnsubscribeResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the UnsubscribeResponse message to JSON.

func (*UnsubscribeResponse) MarshalToSizedBufferVT 

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

func (*UnsubscribeResponse) MarshalToVT 

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

func (*UnsubscribeResponse) MarshalVT 

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

func (*UnsubscribeResponse) ProtoMessage 

func (*UnsubscribeResponse) ProtoMessage()

func (*UnsubscribeResponse) Reset 

func (x *UnsubscribeResponse) Reset()

func (*UnsubscribeResponse) SizeVT 

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

func (*UnsubscribeResponse) UnmarshalJSON added in v0.0.4 

func (x *UnsubscribeResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the UnsubscribeResponse from JSON.

func (*UnsubscribeResponse) UnmarshalProtoJSON added in v0.0.4 

func (x *UnsubscribeResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the UnsubscribeResponse message from JSON.

func (*UnsubscribeResponse) UnmarshalVT 

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

Source Files

View all Source files

Directories

Path Synopsis
svc
build

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.