known

Documentation

Index

• Constants
• Variables
• func WazeroModuleConfig(moduleConfig wazero.ModuleConfig) wazeroConfigOption
• func WazeroRuntime(newRuntime WazeroNewRuntime) wazeroConfigOption
• type DiffReply
  • func (x *DiffReply) GetDuration() *durationpb.Duration
  • func (m *DiffReply) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *DiffReply) MarshalToVT(dAtA []byte) (int, error)
  • func (m *DiffReply) MarshalVT() (dAtA []byte, err error)
  • func (x *DiffReply) ProtoReflect() protoreflect.Message
  • func (m *DiffReply) SizeVT() (n int)
  • func (m *DiffReply) UnmarshalVT(dAtA []byte) error
• type DiffRequest
  • func (x *DiffRequest) GetEnd() *timestamppb.Timestamp
  • func (x *DiffRequest) GetStart() *timestamppb.Timestamp
  • func (x *DiffRequest) GetValue() *structpb.Value
  • func (m *DiffRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *DiffRequest) MarshalToVT(dAtA []byte) (int, error)
  • func (m *DiffRequest) MarshalVT() (dAtA []byte, err error)
  • func (x *DiffRequest) ProtoReflect() protoreflect.Message
  • func (m *DiffRequest) SizeVT() (n int)
  • func (m *DiffRequest) UnmarshalVT(dAtA []byte) error
• type WazeroConfig
• type WazeroNewRuntime
  • func DefaultWazeroRuntime() WazeroNewRuntime
• type WellKnown
• type WellKnownPlugin
  • func NewWellKnownPlugin(ctx context.Context, opts ...wazeroConfigOption) (*WellKnownPlugin, error)
  • func (p *WellKnownPlugin) Load(ctx context.Context, pluginPath string) (wellKnown, error)

Constants

const WellKnownPluginAPIVersion = 1

Variables

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

func WazeroModuleConfig

func WazeroModuleConfig(moduleConfig wazero.ModuleConfig) wazeroConfigOption

func WazeroRuntime

func WazeroRuntime(newRuntime WazeroNewRuntime) wazeroConfigOption

Types

type DiffReply

type DiffReply struct {
	Duration *durationpb.Duration `protobuf:"bytes,1,opt,name=duration,proto3" json:"duration,omitempty"`
	// contains filtered or unexported fields
}

func (*DiffReply) GetDuration

func (x *DiffReply) GetDuration() *durationpb.Duration

func (*DiffReply) MarshalToSizedBufferVT

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

func (*DiffReply) MarshalToVT

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

func (*DiffReply) MarshalVT

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

func (*DiffReply) ProtoReflect

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

func (*DiffReply) SizeVT

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

func (*DiffReply) UnmarshalVT

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

type DiffRequest

type DiffRequest struct {
	Value *structpb.Value        `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Start *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=start,proto3" json:"start,omitempty"`
	End   *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

func (*DiffRequest) GetEnd

func (x *DiffRequest) GetEnd() *timestamppb.Timestamp

func (*DiffRequest) GetStart

func (x *DiffRequest) GetStart() *timestamppb.Timestamp

func (*DiffRequest) GetValue

func (x *DiffRequest) GetValue() *structpb.Value

func (*DiffRequest) MarshalToSizedBufferVT

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

func (*DiffRequest) MarshalToVT

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

func (*DiffRequest) MarshalVT

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

func (*DiffRequest) ProtoReflect

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

func (*DiffRequest) SizeVT

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

func (*DiffRequest) UnmarshalVT

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

type WazeroConfig

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

type WazeroNewRuntime

type WazeroNewRuntime func(context.Context) (wazero.Runtime, error)

func DefaultWazeroRuntime

func DefaultWazeroRuntime() WazeroNewRuntime

type WellKnown

type WellKnown interface {
	Diff(context.Context, *DiffRequest) (*DiffReply, error)
}

The greeting service definition. go:plugin type=plugin

type WellKnownPlugin

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

func NewWellKnownPlugin

func NewWellKnownPlugin(ctx context.Context, opts ...wazeroConfigOption) (*WellKnownPlugin, error)

func (*WellKnownPlugin) Load

func (p *WellKnownPlugin) Load(ctx context.Context, pluginPath string) (wellKnown, error)