s4wave_status

package
v0.51.7 Latest Latest
Warning

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

 Go to latest Published: May 30, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const SRPCSystemStatusServiceServiceID = "s4wave.status.SystemStatusService"

Variables

This section is empty.

Functions

func NewSRPCSystemStatusServiceHandler 

func NewSRPCSystemStatusServiceHandler(impl SRPCSystemStatusServiceServer, serviceID string) srpc.Handler

NewSRPCSystemStatusServiceHandler constructs a new RPC handler. serviceID: if empty, uses default: s4wave.status.SystemStatusService

func SRPCRegisterSystemStatusService 

func SRPCRegisterSystemStatusService(mux srpc.Mux, impl SRPCSystemStatusServiceServer) error

SRPCRegisterSystemStatusService registers the implementation with the mux. Uses the default serviceID: s4wave.status.SystemStatusService

Types

type ControllerInfo 

type ControllerInfo struct {

	// Id is the controller identifier.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Version is the controller version string.
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// Description is a human-readable description.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

ControllerInfo describes a running controller.

func (*ControllerInfo) CloneMessageVT 

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

func (*ControllerInfo) CloneVT 

func (m *ControllerInfo) CloneVT() *ControllerInfo

func (*ControllerInfo) EqualMessageVT 

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

func (*ControllerInfo) EqualVT 

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

func (*ControllerInfo) GetDescription 

func (x *ControllerInfo) GetDescription() string

func (*ControllerInfo) GetId 

func (x *ControllerInfo) GetId() string

func (*ControllerInfo) GetVersion 

func (x *ControllerInfo) GetVersion() string

func (*ControllerInfo) MarshalJSON 

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

MarshalJSON marshals the ControllerInfo to JSON.

func (*ControllerInfo) MarshalProtoJSON 

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

MarshalProtoJSON marshals the ControllerInfo message to JSON.

func (*ControllerInfo) MarshalProtoText 

func (x *ControllerInfo) MarshalProtoText() string

func (*ControllerInfo) MarshalToSizedBufferVT 

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

func (*ControllerInfo) MarshalToVT 

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

func (*ControllerInfo) MarshalVT 

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

func (*ControllerInfo) ProtoMessage 

func (*ControllerInfo) ProtoMessage()

func (*ControllerInfo) Reset 

func (x *ControllerInfo) Reset()

func (*ControllerInfo) SizeVT 

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

func (*ControllerInfo) String 

func (x *ControllerInfo) String() string

func (*ControllerInfo) UnmarshalJSON 

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

UnmarshalJSON unmarshals the ControllerInfo from JSON.

func (*ControllerInfo) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the ControllerInfo message from JSON.

func (*ControllerInfo) UnmarshalVT 

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

type DirectiveInfo 

type DirectiveInfo struct {

	// Name is the directive type name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Ident is the human-readable directive identification string.
	Ident string `protobuf:"bytes,2,opt,name=ident,proto3" json:"ident,omitempty"`
	// contains filtered or unexported fields
}

DirectiveInfo describes an active directive.

func (*DirectiveInfo) CloneMessageVT 

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

func (*DirectiveInfo) CloneVT 

func (m *DirectiveInfo) CloneVT() *DirectiveInfo

func (*DirectiveInfo) EqualMessageVT 

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

func (*DirectiveInfo) EqualVT 

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

func (*DirectiveInfo) GetIdent 

func (x *DirectiveInfo) GetIdent() string

func (*DirectiveInfo) GetName 

func (x *DirectiveInfo) GetName() string

func (*DirectiveInfo) MarshalJSON 

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

MarshalJSON marshals the DirectiveInfo to JSON.

func (*DirectiveInfo) MarshalProtoJSON 

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

MarshalProtoJSON marshals the DirectiveInfo message to JSON.

func (*DirectiveInfo) MarshalProtoText 

func (x *DirectiveInfo) MarshalProtoText() string

func (*DirectiveInfo) MarshalToSizedBufferVT 

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

func (*DirectiveInfo) MarshalToVT 

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

func (*DirectiveInfo) MarshalVT 

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

func (*DirectiveInfo) ProtoMessage 

func (*DirectiveInfo) ProtoMessage()

func (*DirectiveInfo) Reset 

func (x *DirectiveInfo) Reset()

func (*DirectiveInfo) SizeVT 

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

func (*DirectiveInfo) String 

func (x *DirectiveInfo) String() string

func (*DirectiveInfo) UnmarshalJSON 

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

UnmarshalJSON unmarshals the DirectiveInfo from JSON.

func (*DirectiveInfo) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the DirectiveInfo message from JSON.

func (*DirectiveInfo) UnmarshalVT 

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

type PluginInfo added in v0.51.0 

type PluginInfo struct {

	// Id is the plugin identifier.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// InstanceKey is the optional instance key for instanced plugins.
	InstanceKey string `protobuf:"bytes,2,opt,name=instance_key,json=instanceKey,proto3" json:"instanceKey,omitempty"`
	// State is the plugin runtime state.
	State string `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

PluginInfo describes a runtime plugin load request.

func (*PluginInfo) CloneMessageVT added in v0.51.0 

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

func (*PluginInfo) CloneVT added in v0.51.0 

func (m *PluginInfo) CloneVT() *PluginInfo

func (*PluginInfo) EqualMessageVT added in v0.51.0 

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

func (*PluginInfo) EqualVT added in v0.51.0 

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

func (*PluginInfo) GetId added in v0.51.0 

func (x *PluginInfo) GetId() string

func (*PluginInfo) GetInstanceKey added in v0.51.0 

func (x *PluginInfo) GetInstanceKey() string

func (*PluginInfo) GetState added in v0.51.0 

func (x *PluginInfo) GetState() string

func (*PluginInfo) MarshalJSON added in v0.51.0 

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

MarshalJSON marshals the PluginInfo to JSON.

func (*PluginInfo) MarshalProtoJSON added in v0.51.0 

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

MarshalProtoJSON marshals the PluginInfo message to JSON.

func (*PluginInfo) MarshalProtoText added in v0.51.0 

func (x *PluginInfo) MarshalProtoText() string

func (*PluginInfo) MarshalToSizedBufferVT added in v0.51.0 

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

func (*PluginInfo) MarshalToVT added in v0.51.0 

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

func (*PluginInfo) MarshalVT added in v0.51.0 

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

func (*PluginInfo) ProtoMessage added in v0.51.0 

func (*PluginInfo) ProtoMessage()

func (*PluginInfo) Reset added in v0.51.0 

func (x *PluginInfo) Reset()

func (*PluginInfo) SizeVT added in v0.51.0 

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

func (*PluginInfo) String added in v0.51.0 

func (x *PluginInfo) String() string

func (*PluginInfo) UnmarshalJSON added in v0.51.0 

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

UnmarshalJSON unmarshals the PluginInfo from JSON.

func (*PluginInfo) UnmarshalProtoJSON added in v0.51.0 

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

UnmarshalProtoJSON unmarshals the PluginInfo message from JSON.

func (*PluginInfo) UnmarshalVT added in v0.51.0 

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

type SRPCSystemStatusServiceClient 

type SRPCSystemStatusServiceClient interface {
	// SRPCClient returns the underlying SRPC client.
	SRPCClient() srpc.Client

	WatchControllers(ctx context.Context, in *WatchControllersRequest) (SRPCSystemStatusService_WatchControllersClient, error)

	WatchDirectives(ctx context.Context, in *WatchDirectivesRequest) (SRPCSystemStatusService_WatchDirectivesClient, error)

	WatchPlugins(ctx context.Context, in *WatchPluginsRequest) (SRPCSystemStatusService_WatchPluginsClient, error)
}

func NewSRPCSystemStatusServiceClient 

func NewSRPCSystemStatusServiceClient(cc srpc.Client) SRPCSystemStatusServiceClient

func NewSRPCSystemStatusServiceClientWithServiceID 

func NewSRPCSystemStatusServiceClientWithServiceID(cc srpc.Client, serviceID string) SRPCSystemStatusServiceClient

type SRPCSystemStatusServiceHandler 

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

func (SRPCSystemStatusServiceHandler) GetMethodIDs 

func (SRPCSystemStatusServiceHandler) GetMethodIDs() []string

func (*SRPCSystemStatusServiceHandler) GetServiceID 

func (d *SRPCSystemStatusServiceHandler) GetServiceID() string

func (*SRPCSystemStatusServiceHandler) InvokeMethod 

func (d *SRPCSystemStatusServiceHandler) InvokeMethod(
	serviceID, methodID string,
	strm srpc.Stream,
) (bool, error)

func (SRPCSystemStatusServiceHandler) InvokeMethod_WatchControllers 

func (SRPCSystemStatusServiceHandler) InvokeMethod_WatchControllers(impl SRPCSystemStatusServiceServer, strm srpc.Stream) error

func (SRPCSystemStatusServiceHandler) InvokeMethod_WatchDirectives 

func (SRPCSystemStatusServiceHandler) InvokeMethod_WatchDirectives(impl SRPCSystemStatusServiceServer, strm srpc.Stream) error

func (SRPCSystemStatusServiceHandler) InvokeMethod_WatchPlugins added in v0.51.0 

func (SRPCSystemStatusServiceHandler) InvokeMethod_WatchPlugins(impl SRPCSystemStatusServiceServer, strm srpc.Stream) error

type SRPCSystemStatusServiceServer 

type SRPCSystemStatusServiceServer interface {
	WatchControllers(*WatchControllersRequest, SRPCSystemStatusService_WatchControllersStream) error

	WatchDirectives(*WatchDirectivesRequest, SRPCSystemStatusService_WatchDirectivesStream) error

	WatchPlugins(*WatchPluginsRequest, SRPCSystemStatusService_WatchPluginsStream) error
}

type SRPCSystemStatusService_WatchControllersClient 

type SRPCSystemStatusService_WatchControllersClient interface {
	srpc.Stream
	Recv() (*WatchControllersResponse, error)
	RecvTo(*WatchControllersResponse) error
}

type SRPCSystemStatusService_WatchControllersStream 

type SRPCSystemStatusService_WatchControllersStream interface {
	srpc.Stream
	Send(*WatchControllersResponse) error
	SendAndClose(*WatchControllersResponse) error
}

type SRPCSystemStatusService_WatchDirectivesClient 

type SRPCSystemStatusService_WatchDirectivesClient interface {
	srpc.Stream
	Recv() (*WatchDirectivesResponse, error)
	RecvTo(*WatchDirectivesResponse) error
}

type SRPCSystemStatusService_WatchDirectivesStream 

type SRPCSystemStatusService_WatchDirectivesStream interface {
	srpc.Stream
	Send(*WatchDirectivesResponse) error
	SendAndClose(*WatchDirectivesResponse) error
}

type SRPCSystemStatusService_WatchPluginsClient added in v0.51.0 

type SRPCSystemStatusService_WatchPluginsClient interface {
	srpc.Stream
	Recv() (*WatchPluginsResponse, error)
	RecvTo(*WatchPluginsResponse) error
}

type SRPCSystemStatusService_WatchPluginsStream added in v0.51.0 

type SRPCSystemStatusService_WatchPluginsStream interface {
	srpc.Stream
	Send(*WatchPluginsResponse) error
	SendAndClose(*WatchPluginsResponse) error
}

type WatchControllersRequest 

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

WatchControllersRequest is the request type for WatchControllers.

func (*WatchControllersRequest) CloneMessageVT 

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

func (*WatchControllersRequest) CloneVT 

func (m *WatchControllersRequest) CloneVT() *WatchControllersRequest

func (*WatchControllersRequest) EqualMessageVT 

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

func (*WatchControllersRequest) EqualVT 

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

func (*WatchControllersRequest) MarshalJSON 

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

MarshalJSON marshals the WatchControllersRequest to JSON.

func (*WatchControllersRequest) MarshalProtoJSON 

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

MarshalProtoJSON marshals the WatchControllersRequest message to JSON.

func (*WatchControllersRequest) MarshalProtoText 

func (x *WatchControllersRequest) MarshalProtoText() string

func (*WatchControllersRequest) MarshalToSizedBufferVT 

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

func (*WatchControllersRequest) MarshalToVT 

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

func (*WatchControllersRequest) MarshalVT 

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

func (*WatchControllersRequest) ProtoMessage 

func (*WatchControllersRequest) ProtoMessage()

func (*WatchControllersRequest) Reset 

func (x *WatchControllersRequest) Reset()

func (*WatchControllersRequest) SizeVT 

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

func (*WatchControllersRequest) String 

func (x *WatchControllersRequest) String() string

func (*WatchControllersRequest) UnmarshalJSON 

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

UnmarshalJSON unmarshals the WatchControllersRequest from JSON.

func (*WatchControllersRequest) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the WatchControllersRequest message from JSON.

func (*WatchControllersRequest) UnmarshalVT 

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

type WatchControllersResponse 

type WatchControllersResponse struct {

	// Controllers is the current list of active controllers.
	Controllers []*ControllerInfo `protobuf:"bytes,1,rep,name=controllers,proto3" json:"controllers,omitempty"`
	// ControllerCount is the total number of active controllers.
	ControllerCount uint32 `protobuf:"varint,2,opt,name=controller_count,json=controllerCount,proto3" json:"controllerCount,omitempty"`
	// contains filtered or unexported fields
}

WatchControllersResponse is the response type for WatchControllers.

func (*WatchControllersResponse) CloneMessageVT 

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

func (*WatchControllersResponse) CloneVT 

func (m *WatchControllersResponse) CloneVT() *WatchControllersResponse

func (*WatchControllersResponse) EqualMessageVT 

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

func (*WatchControllersResponse) EqualVT 

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

func (*WatchControllersResponse) GetControllerCount 

func (x *WatchControllersResponse) GetControllerCount() uint32

func (*WatchControllersResponse) GetControllers 

func (x *WatchControllersResponse) GetControllers() []*ControllerInfo

func (*WatchControllersResponse) MarshalJSON 

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

MarshalJSON marshals the WatchControllersResponse to JSON.

func (*WatchControllersResponse) MarshalProtoJSON 

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

MarshalProtoJSON marshals the WatchControllersResponse message to JSON.

func (*WatchControllersResponse) MarshalProtoText 

func (x *WatchControllersResponse) MarshalProtoText() string

func (*WatchControllersResponse) MarshalToSizedBufferVT 

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

func (*WatchControllersResponse) MarshalToVT 

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

func (*WatchControllersResponse) MarshalVT 

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

func (*WatchControllersResponse) ProtoMessage 

func (*WatchControllersResponse) ProtoMessage()

func (*WatchControllersResponse) Reset 

func (x *WatchControllersResponse) Reset()

func (*WatchControllersResponse) SizeVT 

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

func (*WatchControllersResponse) String 

func (x *WatchControllersResponse) String() string

func (*WatchControllersResponse) UnmarshalJSON 

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

UnmarshalJSON unmarshals the WatchControllersResponse from JSON.

func (*WatchControllersResponse) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the WatchControllersResponse message from JSON.

func (*WatchControllersResponse) UnmarshalVT 

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

type WatchDirectivesRequest 

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

WatchDirectivesRequest is the request type for WatchDirectives.

func (*WatchDirectivesRequest) CloneMessageVT 

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

func (*WatchDirectivesRequest) CloneVT 

func (m *WatchDirectivesRequest) CloneVT() *WatchDirectivesRequest

func (*WatchDirectivesRequest) EqualMessageVT 

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

func (*WatchDirectivesRequest) EqualVT 

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

func (*WatchDirectivesRequest) MarshalJSON 

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

MarshalJSON marshals the WatchDirectivesRequest to JSON.

func (*WatchDirectivesRequest) MarshalProtoJSON 

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

MarshalProtoJSON marshals the WatchDirectivesRequest message to JSON.

func (*WatchDirectivesRequest) MarshalProtoText 

func (x *WatchDirectivesRequest) MarshalProtoText() string

func (*WatchDirectivesRequest) MarshalToSizedBufferVT 

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

func (*WatchDirectivesRequest) MarshalToVT 

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

func (*WatchDirectivesRequest) MarshalVT 

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

func (*WatchDirectivesRequest) ProtoMessage 

func (*WatchDirectivesRequest) ProtoMessage()

func (*WatchDirectivesRequest) Reset 

func (x *WatchDirectivesRequest) Reset()

func (*WatchDirectivesRequest) SizeVT 

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

func (*WatchDirectivesRequest) String 

func (x *WatchDirectivesRequest) String() string

func (*WatchDirectivesRequest) UnmarshalJSON 

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

UnmarshalJSON unmarshals the WatchDirectivesRequest from JSON.

func (*WatchDirectivesRequest) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the WatchDirectivesRequest message from JSON.

func (*WatchDirectivesRequest) UnmarshalVT 

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

type WatchDirectivesResponse 

type WatchDirectivesResponse struct {

	// Directives is the current list of active directives.
	Directives []*DirectiveInfo `protobuf:"bytes,1,rep,name=directives,proto3" json:"directives,omitempty"`
	// DirectiveCount is the total number of active directives.
	DirectiveCount uint32 `protobuf:"varint,2,opt,name=directive_count,json=directiveCount,proto3" json:"directiveCount,omitempty"`
	// contains filtered or unexported fields
}

WatchDirectivesResponse is the response type for WatchDirectives.

func (*WatchDirectivesResponse) CloneMessageVT 

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

func (*WatchDirectivesResponse) CloneVT 

func (m *WatchDirectivesResponse) CloneVT() *WatchDirectivesResponse

func (*WatchDirectivesResponse) EqualMessageVT 

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

func (*WatchDirectivesResponse) EqualVT 

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

func (*WatchDirectivesResponse) GetDirectiveCount 

func (x *WatchDirectivesResponse) GetDirectiveCount() uint32

func (*WatchDirectivesResponse) GetDirectives 

func (x *WatchDirectivesResponse) GetDirectives() []*DirectiveInfo

func (*WatchDirectivesResponse) MarshalJSON 

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

MarshalJSON marshals the WatchDirectivesResponse to JSON.

func (*WatchDirectivesResponse) MarshalProtoJSON 

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

MarshalProtoJSON marshals the WatchDirectivesResponse message to JSON.

func (*WatchDirectivesResponse) MarshalProtoText 

func (x *WatchDirectivesResponse) MarshalProtoText() string

func (*WatchDirectivesResponse) MarshalToSizedBufferVT 

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

func (*WatchDirectivesResponse) MarshalToVT 

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

func (*WatchDirectivesResponse) MarshalVT 

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

func (*WatchDirectivesResponse) ProtoMessage 

func (*WatchDirectivesResponse) ProtoMessage()

func (*WatchDirectivesResponse) Reset 

func (x *WatchDirectivesResponse) Reset()

func (*WatchDirectivesResponse) SizeVT 

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

func (*WatchDirectivesResponse) String 

func (x *WatchDirectivesResponse) String() string

func (*WatchDirectivesResponse) UnmarshalJSON 

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

UnmarshalJSON unmarshals the WatchDirectivesResponse from JSON.

func (*WatchDirectivesResponse) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the WatchDirectivesResponse message from JSON.

func (*WatchDirectivesResponse) UnmarshalVT 

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

type WatchPluginsRequest added in v0.51.0 

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

WatchPluginsRequest is the request type for WatchPlugins.

func (*WatchPluginsRequest) CloneMessageVT added in v0.51.0 

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

func (*WatchPluginsRequest) CloneVT added in v0.51.0 

func (m *WatchPluginsRequest) CloneVT() *WatchPluginsRequest

func (*WatchPluginsRequest) EqualMessageVT added in v0.51.0 

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

func (*WatchPluginsRequest) EqualVT added in v0.51.0 

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

func (*WatchPluginsRequest) MarshalJSON added in v0.51.0 

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

MarshalJSON marshals the WatchPluginsRequest to JSON.

func (*WatchPluginsRequest) MarshalProtoJSON added in v0.51.0 

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

MarshalProtoJSON marshals the WatchPluginsRequest message to JSON.

func (*WatchPluginsRequest) MarshalProtoText added in v0.51.0 

func (x *WatchPluginsRequest) MarshalProtoText() string

func (*WatchPluginsRequest) MarshalToSizedBufferVT added in v0.51.0 

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

func (*WatchPluginsRequest) MarshalToVT added in v0.51.0 

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

func (*WatchPluginsRequest) MarshalVT added in v0.51.0 

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

func (*WatchPluginsRequest) ProtoMessage added in v0.51.0 

func (*WatchPluginsRequest) ProtoMessage()

func (*WatchPluginsRequest) Reset added in v0.51.0 

func (x *WatchPluginsRequest) Reset()

func (*WatchPluginsRequest) SizeVT added in v0.51.0 

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

func (*WatchPluginsRequest) String added in v0.51.0 

func (x *WatchPluginsRequest) String() string

func (*WatchPluginsRequest) UnmarshalJSON added in v0.51.0 

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

UnmarshalJSON unmarshals the WatchPluginsRequest from JSON.

func (*WatchPluginsRequest) UnmarshalProtoJSON added in v0.51.0 

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

UnmarshalProtoJSON unmarshals the WatchPluginsRequest message from JSON.

func (*WatchPluginsRequest) UnmarshalVT added in v0.51.0 

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

type WatchPluginsResponse added in v0.51.0 

type WatchPluginsResponse struct {

	// Plugins is the current list of plugin load requests.
	Plugins []*PluginInfo `protobuf:"bytes,1,rep,name=plugins,proto3" json:"plugins,omitempty"`
	// PluginCount is the total number of plugin load requests.
	PluginCount uint32 `protobuf:"varint,2,opt,name=plugin_count,json=pluginCount,proto3" json:"pluginCount,omitempty"`
	// contains filtered or unexported fields
}

WatchPluginsResponse is the response type for WatchPlugins.

func (*WatchPluginsResponse) CloneMessageVT added in v0.51.0 

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

func (*WatchPluginsResponse) CloneVT added in v0.51.0 

func (m *WatchPluginsResponse) CloneVT() *WatchPluginsResponse

func (*WatchPluginsResponse) EqualMessageVT added in v0.51.0 

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

func (*WatchPluginsResponse) EqualVT added in v0.51.0 

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

func (*WatchPluginsResponse) GetPluginCount added in v0.51.0 

func (x *WatchPluginsResponse) GetPluginCount() uint32

func (*WatchPluginsResponse) GetPlugins added in v0.51.0 

func (x *WatchPluginsResponse) GetPlugins() []*PluginInfo

func (*WatchPluginsResponse) MarshalJSON added in v0.51.0 

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

MarshalJSON marshals the WatchPluginsResponse to JSON.

func (*WatchPluginsResponse) MarshalProtoJSON added in v0.51.0 

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

MarshalProtoJSON marshals the WatchPluginsResponse message to JSON.

func (*WatchPluginsResponse) MarshalProtoText added in v0.51.0 

func (x *WatchPluginsResponse) MarshalProtoText() string

func (*WatchPluginsResponse) MarshalToSizedBufferVT added in v0.51.0 

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

func (*WatchPluginsResponse) MarshalToVT added in v0.51.0 

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

func (*WatchPluginsResponse) MarshalVT added in v0.51.0 

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

func (*WatchPluginsResponse) ProtoMessage added in v0.51.0 

func (*WatchPluginsResponse) ProtoMessage()

func (*WatchPluginsResponse) Reset added in v0.51.0 

func (x *WatchPluginsResponse) Reset()

func (*WatchPluginsResponse) SizeVT added in v0.51.0 

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

func (*WatchPluginsResponse) String added in v0.51.0 

func (x *WatchPluginsResponse) String() string

func (*WatchPluginsResponse) UnmarshalJSON added in v0.51.0 

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

UnmarshalJSON unmarshals the WatchPluginsResponse from JSON.

func (*WatchPluginsResponse) UnmarshalProtoJSON added in v0.51.0 

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

UnmarshalProtoJSON unmarshals the WatchPluginsResponse message from JSON.

func (*WatchPluginsResponse) UnmarshalVT added in v0.51.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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