api

package
v0.9.0 Latest Latest
Warning

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

 Go to latest Published: Jan 8, 2025 License: GPL-3.0 Imports: 15 Imported by: 0

Documentation

Overview

Package api contains the RSCA protobuf files and definitions.

Index

Constants

View Source 
const (
	Admin_ListHosts_FullMethodName   = "/rsca.api.Admin/ListHosts"
	Admin_RemoveHost_FullMethodName  = "/rsca.api.Admin/RemoveHost"
	Admin_TriggerAll_FullMethodName  = "/rsca.api.Admin/TriggerAll"
	Admin_TriggerInfo_FullMethodName = "/rsca.api.Admin/TriggerInfo"
)
View Source 
const Message_EventMessage_case case_Message_Message = 103
View Source 
const Message_MemberUpdateMessage_case case_Message_Message = 106
View Source 
const Message_Message_not_set_case case_Message_Message = 0
View Source 
const Message_PingMessage_case case_Message_Message = 101
View Source 
const Message_PongMessage_case case_Message_Message = 102
View Source 
const Message_RegisterMessage_case case_Message_Message = 100
View Source 
const Message_RepeatRegistrationMessage_case case_Message_Message = 105
View Source 
const Message_TriggerAllMessage_case case_Message_Message = 104
View Source 
const (
	RSCA_Pipe_FullMethodName = "/rsca.api.RSCA/Pipe"
)

Variables

View Source 
var (
	Status_name = map[int32]string{
		0: "OK",
		1: "WARNING",
		2: "CRITICAL",
		3: "UNKNOWN",
	}
	Status_value = map[string]int32{
		"OK":       0,
		"WARNING":  1,
		"CRITICAL": 2,
		"UNKNOWN":  3,
	}
)

Enum value maps for Status.

View Source 
var (
	CheckType_name = map[int32]string{
		0: "HOST",
		1: "SERVICE",
	}
	CheckType_value = map[string]int32{
		"HOST":    0,
		"SERVICE": 1,
	}
)

Enum value maps for CheckType.

View Source 
var Admin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rsca.api.Admin",
	HandlerType: (*AdminServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RemoveHost",
			Handler:    _Admin_RemoveHost_Handler,
		},
		{
			MethodName: "TriggerAll",
			Handler:    _Admin_TriggerAll_Handler,
		},
		{
			MethodName: "TriggerInfo",
			Handler:    _Admin_TriggerInfo_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ListHosts",
			Handler:       _Admin_ListHosts_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "github.com/na4ma4/rsca/api/admin.proto",
}

Admin_ServiceDesc is the grpc.ServiceDesc for Admin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_github_com_na4ma4_rsca_api_admin_proto protoreflect.FileDescriptor
View Source 
var File_github_com_na4ma4_rsca_api_api_proto protoreflect.FileDescriptor
View Source 
var File_github_com_na4ma4_rsca_api_common_proto protoreflect.FileDescriptor
View Source 
var RSCA_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rsca.api.RSCA",
	HandlerType: (*RSCAServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Pipe",
			Handler:       _RSCA_Pipe_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "github.com/na4ma4/rsca/api/api.proto",
}

RSCA_ServiceDesc is the grpc.ServiceDesc for RSCA service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterAdminServer 

func RegisterAdminServer(s grpc.ServiceRegistrar, srv AdminServer)

func RegisterRSCAServer 

func RegisterRSCAServer(s grpc.ServiceRegistrar, srv RSCAServer)

Types

type AdminClient 

type AdminClient interface {
	ListHosts(ctx context.Context, in *Empty, opts ...grpc.CallOption) (grpc.ServerStreamingClient[Member], error)
	RemoveHost(ctx context.Context, in *RemoveHostRequest, opts ...grpc.CallOption) (*RemoveHostResponse, error)
	TriggerAll(ctx context.Context, in *Members, opts ...grpc.CallOption) (*TriggerAllResponse, error)
	TriggerInfo(ctx context.Context, in *Members, opts ...grpc.CallOption) (*TriggerInfoResponse, error)
}

AdminClient is the client API for Admin service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAdminClient 

func NewAdminClient(cc grpc.ClientConnInterface) AdminClient

type AdminServer 

type AdminServer interface {
	ListHosts(*Empty, grpc.ServerStreamingServer[Member]) error
	RemoveHost(context.Context, *RemoveHostRequest) (*RemoveHostResponse, error)
	TriggerAll(context.Context, *Members) (*TriggerAllResponse, error)
	TriggerInfo(context.Context, *Members) (*TriggerInfoResponse, error)
}

AdminServer is the server API for Admin service. All implementations should embed UnimplementedAdminServer for forward compatibility.

type Admin_ListHostsClient 

type Admin_ListHostsClient = grpc.ServerStreamingClient[Member]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Admin_ListHostsServer 

type Admin_ListHostsServer = grpc.ServerStreamingServer[Member]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type CheckType 

type CheckType int32
const (
	CheckType_HOST    CheckType = 0
	CheckType_SERVICE CheckType = 1
)

func (CheckType) Descriptor 

func (CheckType) Descriptor() protoreflect.EnumDescriptor

func (CheckType) Enum 

func (x CheckType) Enum() *CheckType

func (CheckType) Number 

func (x CheckType) Number() protoreflect.EnumNumber

func (CheckType) String 

func (x CheckType) String() string

func (CheckType) Type 

func (CheckType) Type() protoreflect.EnumType

type Empty 

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

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

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

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type Empty_builder added in v0.9.0 

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

func (Empty_builder) Build added in v0.9.0 

func (b0 Empty_builder) Build() *Empty

type Envelope 

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

func (*Envelope) ClearRecipient added in v0.9.0 

func (x *Envelope) ClearRecipient()

func (*Envelope) ClearSender added in v0.9.0 

func (x *Envelope) ClearSender()

func (*Envelope) GetRecipient 

func (x *Envelope) GetRecipient() *Members

func (*Envelope) GetSender 

func (x *Envelope) GetSender() *Member

func (*Envelope) HasRecipient added in v0.9.0 

func (x *Envelope) HasRecipient() bool

func (*Envelope) HasSender added in v0.9.0 

func (x *Envelope) HasSender() bool

func (*Envelope) ProtoMessage 

func (*Envelope) ProtoMessage()

func (*Envelope) ProtoReflect 

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

func (*Envelope) Reset 

func (x *Envelope) Reset()

func (*Envelope) SetRecipient added in v0.9.0 

func (x *Envelope) SetRecipient(v *Members)

func (*Envelope) SetSender added in v0.9.0 

func (x *Envelope) SetSender(v *Member)

func (*Envelope) String 

func (x *Envelope) String() string

type Envelope_builder added in v0.9.0 

type Envelope_builder struct {
	Sender    *Member
	Recipient *Members
	// contains filtered or unexported fields
}

func (Envelope_builder) Build added in v0.9.0 

func (b0 Envelope_builder) Build() *Envelope

type EventMessage 

type EventMessage struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (*EventMessage) ClearCheck added in v0.9.0 

func (x *EventMessage) ClearCheck()

func (*EventMessage) ClearHostname added in v0.9.0 

func (x *EventMessage) ClearHostname()

func (*EventMessage) ClearId added in v0.9.0 

func (x *EventMessage) ClearId()

func (*EventMessage) ClearOutput added in v0.9.0 

func (x *EventMessage) ClearOutput()

func (*EventMessage) ClearOutputError added in v0.9.0 

func (x *EventMessage) ClearOutputError()

func (*EventMessage) ClearPerfdata added in v0.9.0 

func (x *EventMessage) ClearPerfdata()

func (*EventMessage) ClearRequestTimestamp added in v0.9.0 

func (x *EventMessage) ClearRequestTimestamp()

func (*EventMessage) ClearRetries added in v0.9.0 

func (x *EventMessage) ClearRetries()

func (*EventMessage) ClearStatus added in v0.9.0 

func (x *EventMessage) ClearStatus()

func (*EventMessage) ClearType added in v0.9.0 

func (x *EventMessage) ClearType()

func (*EventMessage) GetCheck 

func (x *EventMessage) GetCheck() string

func (*EventMessage) GetHostname 

func (x *EventMessage) GetHostname() string

func (*EventMessage) GetId 

func (x *EventMessage) GetId() string

func (*EventMessage) GetOutput 

func (x *EventMessage) GetOutput() string

func (*EventMessage) GetOutputError added in v0.4.0 

func (x *EventMessage) GetOutputError() string

func (*EventMessage) GetPerfdata 

func (x *EventMessage) GetPerfdata() string

func (*EventMessage) GetRequestTimestamp 

func (x *EventMessage) GetRequestTimestamp() *timestamppb.Timestamp

func (*EventMessage) GetRetries 

func (x *EventMessage) GetRetries() int32

func (*EventMessage) GetStatus 

func (x *EventMessage) GetStatus() Status

func (*EventMessage) GetType 

func (x *EventMessage) GetType() CheckType

func (*EventMessage) HasCheck added in v0.9.0 

func (x *EventMessage) HasCheck() bool

func (*EventMessage) HasHostname added in v0.9.0 

func (x *EventMessage) HasHostname() bool

func (*EventMessage) HasId added in v0.9.0 

func (x *EventMessage) HasId() bool

func (*EventMessage) HasOutput added in v0.9.0 

func (x *EventMessage) HasOutput() bool

func (*EventMessage) HasOutputError added in v0.9.0 

func (x *EventMessage) HasOutputError() bool

func (*EventMessage) HasPerfdata added in v0.9.0 

func (x *EventMessage) HasPerfdata() bool

func (*EventMessage) HasRequestTimestamp added in v0.9.0 

func (x *EventMessage) HasRequestTimestamp() bool

func (*EventMessage) HasRetries added in v0.9.0 

func (x *EventMessage) HasRetries() bool

func (*EventMessage) HasStatus added in v0.9.0 

func (x *EventMessage) HasStatus() bool

func (*EventMessage) HasType added in v0.9.0 

func (x *EventMessage) HasType() bool

func (*EventMessage) ProtoMessage 

func (*EventMessage) ProtoMessage()

func (*EventMessage) ProtoReflect 

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

func (*EventMessage) Reset 

func (x *EventMessage) Reset()

func (*EventMessage) SetCheck added in v0.9.0 

func (x *EventMessage) SetCheck(v string)

func (*EventMessage) SetHostname added in v0.9.0 

func (x *EventMessage) SetHostname(v string)

func (*EventMessage) SetId added in v0.9.0 

func (x *EventMessage) SetId(v string)

func (*EventMessage) SetOutput added in v0.9.0 

func (x *EventMessage) SetOutput(v string)

func (*EventMessage) SetOutputError added in v0.9.0 

func (x *EventMessage) SetOutputError(v string)

func (*EventMessage) SetPerfdata added in v0.9.0 

func (x *EventMessage) SetPerfdata(v string)

func (*EventMessage) SetRequestTimestamp added in v0.9.0 

func (x *EventMessage) SetRequestTimestamp(v *timestamppb.Timestamp)

func (*EventMessage) SetRetries added in v0.9.0 

func (x *EventMessage) SetRetries(v int32)

func (*EventMessage) SetStatus added in v0.9.0 

func (x *EventMessage) SetStatus(v Status)

func (*EventMessage) SetType added in v0.9.0 

func (x *EventMessage) SetType(v CheckType)

func (*EventMessage) String 

func (x *EventMessage) String() string

type EventMessage_builder added in v0.9.0 

type EventMessage_builder struct {
	Hostname         *string
	Type             *CheckType
	Check            *string
	Status           *Status
	Output           *string
	OutputError      *string
	Perfdata         *string
	RequestTimestamp *timestamppb.Timestamp
	Retries          *int32
	Id               *string
	// contains filtered or unexported fields
}

func (EventMessage_builder) Build added in v0.9.0 

func (b0 EventMessage_builder) Build() *EventMessage

type InfoStat added in v0.5.0 

type InfoStat struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func InfoWithContext added in v0.5.0 

func InfoWithContext(ctx context.Context, ts time.Time) (*InfoStat, error)

InfoWithContext calls shirou/gopsutil InfoWithContext and returns a native InfoStat for protobuf.

func (*InfoStat) ClearBootTime added in v0.9.0 

func (x *InfoStat) ClearBootTime()

func (*InfoStat) ClearHostId added in v0.9.0 

func (x *InfoStat) ClearHostId()

func (*InfoStat) ClearHostname added in v0.9.0 

func (x *InfoStat) ClearHostname()

func (*InfoStat) ClearKernelArch added in v0.9.0 

func (x *InfoStat) ClearKernelArch()

func (*InfoStat) ClearKernelVersion added in v0.9.0 

func (x *InfoStat) ClearKernelVersion()

func (*InfoStat) ClearOs added in v0.9.0 

func (x *InfoStat) ClearOs()

func (*InfoStat) ClearPlatform added in v0.9.0 

func (x *InfoStat) ClearPlatform()

func (*InfoStat) ClearPlatformFamily added in v0.9.0 

func (x *InfoStat) ClearPlatformFamily()

func (*InfoStat) ClearPlatformVersion added in v0.9.0 

func (x *InfoStat) ClearPlatformVersion()

func (*InfoStat) ClearProcs added in v0.9.0 

func (x *InfoStat) ClearProcs()

func (*InfoStat) ClearTimestamp added in v0.9.0 

func (x *InfoStat) ClearTimestamp()

func (*InfoStat) ClearUptime added in v0.9.0 

func (x *InfoStat) ClearUptime()

func (*InfoStat) ClearVirtRole added in v0.9.0 

func (x *InfoStat) ClearVirtRole()

func (*InfoStat) ClearVirtSystem added in v0.9.0 

func (x *InfoStat) ClearVirtSystem()

func (*InfoStat) GetBootTime added in v0.5.0 

func (x *InfoStat) GetBootTime() uint64

func (*InfoStat) GetHostId added in v0.5.0 

func (x *InfoStat) GetHostId() string

func (*InfoStat) GetHostname added in v0.5.0 

func (x *InfoStat) GetHostname() string

func (*InfoStat) GetKernelArch added in v0.5.0 

func (x *InfoStat) GetKernelArch() string

func (*InfoStat) GetKernelVersion added in v0.5.0 

func (x *InfoStat) GetKernelVersion() string

func (*InfoStat) GetOs added in v0.5.0 

func (x *InfoStat) GetOs() string

func (*InfoStat) GetPlatform added in v0.5.0 

func (x *InfoStat) GetPlatform() string

func (*InfoStat) GetPlatformFamily added in v0.5.0 

func (x *InfoStat) GetPlatformFamily() string

func (*InfoStat) GetPlatformVersion added in v0.5.0 

func (x *InfoStat) GetPlatformVersion() string

func (*InfoStat) GetProcs added in v0.5.0 

func (x *InfoStat) GetProcs() uint64

func (*InfoStat) GetTimestamp added in v0.5.0 

func (x *InfoStat) GetTimestamp() *timestamppb.Timestamp

func (*InfoStat) GetUptime added in v0.5.0 

func (x *InfoStat) GetUptime() uint64

func (*InfoStat) GetVirtRole added in v0.5.0 

func (x *InfoStat) GetVirtRole() string

func (*InfoStat) GetVirtSystem added in v0.5.0 

func (x *InfoStat) GetVirtSystem() string

func (*InfoStat) HasBootTime added in v0.9.0 

func (x *InfoStat) HasBootTime() bool

func (*InfoStat) HasHostId added in v0.9.0 

func (x *InfoStat) HasHostId() bool

func (*InfoStat) HasHostname added in v0.9.0 

func (x *InfoStat) HasHostname() bool

func (*InfoStat) HasKernelArch added in v0.9.0 

func (x *InfoStat) HasKernelArch() bool

func (*InfoStat) HasKernelVersion added in v0.9.0 

func (x *InfoStat) HasKernelVersion() bool

func (*InfoStat) HasOs added in v0.9.0 

func (x *InfoStat) HasOs() bool

func (*InfoStat) HasPlatform added in v0.9.0 

func (x *InfoStat) HasPlatform() bool

func (*InfoStat) HasPlatformFamily added in v0.9.0 

func (x *InfoStat) HasPlatformFamily() bool

func (*InfoStat) HasPlatformVersion added in v0.9.0 

func (x *InfoStat) HasPlatformVersion() bool

func (*InfoStat) HasProcs added in v0.9.0 

func (x *InfoStat) HasProcs() bool

func (*InfoStat) HasTimestamp added in v0.9.0 

func (x *InfoStat) HasTimestamp() bool

func (*InfoStat) HasUptime added in v0.9.0 

func (x *InfoStat) HasUptime() bool

func (*InfoStat) HasVirtRole added in v0.9.0 

func (x *InfoStat) HasVirtRole() bool

func (*InfoStat) HasVirtSystem added in v0.9.0 

func (x *InfoStat) HasVirtSystem() bool

func (*InfoStat) ProtoMessage added in v0.5.0 

func (*InfoStat) ProtoMessage()

func (*InfoStat) ProtoReflect added in v0.5.0 

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

func (*InfoStat) Reset added in v0.5.0 

func (x *InfoStat) Reset()

func (*InfoStat) SetBootTime added in v0.9.0 

func (x *InfoStat) SetBootTime(v uint64)

func (*InfoStat) SetHostId added in v0.9.0 

func (x *InfoStat) SetHostId(v string)

func (*InfoStat) SetHostname added in v0.9.0 

func (x *InfoStat) SetHostname(v string)

func (*InfoStat) SetKernelArch added in v0.9.0 

func (x *InfoStat) SetKernelArch(v string)

func (*InfoStat) SetKernelVersion added in v0.9.0 

func (x *InfoStat) SetKernelVersion(v string)

func (*InfoStat) SetOs added in v0.9.0 

func (x *InfoStat) SetOs(v string)

func (*InfoStat) SetPlatform added in v0.9.0 

func (x *InfoStat) SetPlatform(v string)

func (*InfoStat) SetPlatformFamily added in v0.9.0 

func (x *InfoStat) SetPlatformFamily(v string)

func (*InfoStat) SetPlatformVersion added in v0.9.0 

func (x *InfoStat) SetPlatformVersion(v string)

func (*InfoStat) SetProcs added in v0.9.0 

func (x *InfoStat) SetProcs(v uint64)

func (*InfoStat) SetTimestamp added in v0.9.0 

func (x *InfoStat) SetTimestamp(v *timestamppb.Timestamp)

func (*InfoStat) SetUptime added in v0.9.0 

func (x *InfoStat) SetUptime(v uint64)

func (*InfoStat) SetVirtRole added in v0.9.0 

func (x *InfoStat) SetVirtRole(v string)

func (*InfoStat) SetVirtSystem added in v0.9.0 

func (x *InfoStat) SetVirtSystem(v string)

func (*InfoStat) String added in v0.5.0 

func (x *InfoStat) String() string

type InfoStat_builder added in v0.9.0 

type InfoStat_builder struct {
	Timestamp *timestamppb.Timestamp
	Hostname  *string
	Uptime    *uint64
	BootTime  *uint64
	// number of processes
	Procs *uint64
	// ex: freebsd, linux
	Os *string
	// ex: ubuntu, linuxmint
	Platform *string
	// ex: debian, rhel
	PlatformFamily *string
	// version of the complete OS
	PlatformVersion *string
	// version of the OS kernel (if available)
	KernelVersion *string
	// native cpu architecture queried at runtime, as returned by `uname -m` or empty string in case of error
	KernelArch *string
	VirtSystem *string
	// guest or host
	VirtRole *string
	// ex: uuid
	HostId *string
	// contains filtered or unexported fields
}

func (InfoStat_builder) Build added in v0.9.0 

func (b0 InfoStat_builder) Build() *InfoStat

type Member 

type Member struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (*Member) ClearActive added in v0.9.0 

func (x *Member) ClearActive()

func (*Member) ClearBuildDate added in v0.9.0 

func (x *Member) ClearBuildDate()

func (*Member) ClearGitHash added in v0.9.0 

func (x *Member) ClearGitHash()

func (*Member) ClearId added in v0.9.0 

func (x *Member) ClearId()

func (*Member) ClearInfoStat added in v0.9.0 

func (x *Member) ClearInfoStat()

func (*Member) ClearInternalId added in v0.9.0 

func (x *Member) ClearInternalId()

func (*Member) ClearLastSeen added in v0.9.0 

func (x *Member) ClearLastSeen()

func (*Member) ClearLastSeenAgo added in v0.9.0 

func (x *Member) ClearLastSeenAgo()

func (*Member) ClearLatency added in v0.9.0 

func (x *Member) ClearLatency()

func (*Member) ClearName added in v0.9.0 

func (x *Member) ClearName()

func (*Member) ClearPingLatency added in v0.9.0 

func (x *Member) ClearPingLatency()

func (*Member) ClearProcessStart added in v0.9.0 

func (x *Member) ClearProcessStart()

func (*Member) ClearSystemStart added in v0.9.0 

func (x *Member) ClearSystemStart()

func (*Member) ClearVersion added in v0.9.0 

func (x *Member) ClearVersion()

func (*Member) GetActive added in v0.5.8 

func (x *Member) GetActive() bool

func (*Member) GetBuildDate added in v0.3.0 

func (x *Member) GetBuildDate() string

func (*Member) GetCapability 

func (x *Member) GetCapability() []string

func (*Member) GetGitHash added in v0.3.0 

func (x *Member) GetGitHash() string

func (*Member) GetId 

func (x *Member) GetId() string

func (*Member) GetInfoStat added in v0.5.0 

func (x *Member) GetInfoStat() *InfoStat

func (*Member) GetInternalId 

func (x *Member) GetInternalId() string

func (*Member) GetLastSeen 

func (x *Member) GetLastSeen() *timestamppb.Timestamp

func (*Member) GetLastSeenAgo 

func (x *Member) GetLastSeenAgo() string

func (*Member) GetLatency 

func (x *Member) GetLatency() string

func (*Member) GetName 

func (x *Member) GetName() string

func (*Member) GetPingLatency 

func (x *Member) GetPingLatency() *durationpb.Duration

func (*Member) GetProcessStart added in v0.5.0 

func (x *Member) GetProcessStart() *timestamppb.Timestamp

func (*Member) GetService 

func (x *Member) GetService() []string

func (*Member) GetSystemStart added in v0.5.0 

func (x *Member) GetSystemStart() *timestamppb.Timestamp

func (*Member) GetTag 

func (x *Member) GetTag() []string

func (*Member) GetVersion added in v0.3.0 

func (x *Member) GetVersion() string

func (*Member) HasActive added in v0.9.0 

func (x *Member) HasActive() bool

func (*Member) HasBuildDate added in v0.9.0 

func (x *Member) HasBuildDate() bool

func (*Member) HasGitHash added in v0.9.0 

func (x *Member) HasGitHash() bool

func (*Member) HasId added in v0.9.0 

func (x *Member) HasId() bool

func (*Member) HasInfoStat added in v0.9.0 

func (x *Member) HasInfoStat() bool

func (*Member) HasInternalId added in v0.9.0 

func (x *Member) HasInternalId() bool

func (*Member) HasLastSeen added in v0.9.0 

func (x *Member) HasLastSeen() bool

func (*Member) HasLastSeenAgo added in v0.9.0 

func (x *Member) HasLastSeenAgo() bool

func (*Member) HasLatency added in v0.9.0 

func (x *Member) HasLatency() bool

func (*Member) HasName added in v0.9.0 

func (x *Member) HasName() bool

func (*Member) HasPingLatency added in v0.9.0 

func (x *Member) HasPingLatency() bool

func (*Member) HasProcessStart added in v0.9.0 

func (x *Member) HasProcessStart() bool

func (*Member) HasSystemStart added in v0.9.0 

func (x *Member) HasSystemStart() bool

func (*Member) HasVersion added in v0.9.0 

func (x *Member) HasVersion() bool

func (*Member) IsMatch added in v0.5.6 

func (x *Member) IsMatch(query string) bool

IsMatch returns if a member matches a supplied query string

Query strings can start or end in a * or % to indicate wildcard matching.

func (*Member) ProtoMessage 

func (*Member) ProtoMessage()

func (*Member) ProtoReflect 

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

func (*Member) Reset 

func (x *Member) Reset()

func (*Member) SetActive added in v0.9.0 

func (x *Member) SetActive(v bool)

func (*Member) SetBuildDate added in v0.9.0 

func (x *Member) SetBuildDate(v string)

func (*Member) SetCapability added in v0.9.0 

func (x *Member) SetCapability(v []string)

func (*Member) SetGitHash added in v0.9.0 

func (x *Member) SetGitHash(v string)

func (*Member) SetId added in v0.9.0 

func (x *Member) SetId(v string)

func (*Member) SetInfoStat added in v0.9.0 

func (x *Member) SetInfoStat(v *InfoStat)

func (*Member) SetInternalId added in v0.9.0 

func (x *Member) SetInternalId(v string)

func (*Member) SetLastSeen added in v0.9.0 

func (x *Member) SetLastSeen(v *timestamppb.Timestamp)

func (*Member) SetLastSeenAgo added in v0.9.0 

func (x *Member) SetLastSeenAgo(v string)

func (*Member) SetLatency added in v0.9.0 

func (x *Member) SetLatency(v string)

func (*Member) SetName added in v0.9.0 

func (x *Member) SetName(v string)

func (*Member) SetPingLatency added in v0.9.0 

func (x *Member) SetPingLatency(v *durationpb.Duration)

func (*Member) SetProcessStart added in v0.9.0 

func (x *Member) SetProcessStart(v *timestamppb.Timestamp)

func (*Member) SetService added in v0.9.0 

func (x *Member) SetService(v []string)

func (*Member) SetSystemStart added in v0.9.0 

func (x *Member) SetSystemStart(v *timestamppb.Timestamp)

func (*Member) SetTag added in v0.9.0 

func (x *Member) SetTag(v []string)

func (*Member) SetVersion added in v0.9.0 

func (x *Member) SetVersion(v string)

func (*Member) String 

func (x *Member) String() string

type MemberUpdateMessage added in v0.5.0 

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

func (*MemberUpdateMessage) ClearMember added in v0.9.0 

func (x *MemberUpdateMessage) ClearMember()

func (*MemberUpdateMessage) GetMember added in v0.5.0 

func (x *MemberUpdateMessage) GetMember() *Member

func (*MemberUpdateMessage) HasMember added in v0.9.0 

func (x *MemberUpdateMessage) HasMember() bool

func (*MemberUpdateMessage) ProtoMessage added in v0.5.0 

func (*MemberUpdateMessage) ProtoMessage()

func (*MemberUpdateMessage) ProtoReflect added in v0.5.0 

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

func (*MemberUpdateMessage) Reset added in v0.5.0 

func (x *MemberUpdateMessage) Reset()

func (*MemberUpdateMessage) SetMember added in v0.9.0 

func (x *MemberUpdateMessage) SetMember(v *Member)

func (*MemberUpdateMessage) String added in v0.5.0 

func (x *MemberUpdateMessage) String() string

type MemberUpdateMessage_builder added in v0.9.0 

type MemberUpdateMessage_builder struct {
	Member *Member
	// contains filtered or unexported fields
}

func (MemberUpdateMessage_builder) Build added in v0.9.0 

func (b0 MemberUpdateMessage_builder) Build() *MemberUpdateMessage

type Member_builder added in v0.9.0 

type Member_builder struct {
	Id           *string
	InternalId   *string
	Name         *string
	Capability   []string
	Tag          []string
	Service      []string
	Version      *string
	GitHash      *string
	BuildDate    *string
	LastSeen     *timestamppb.Timestamp
	PingLatency  *durationpb.Duration
	InfoStat     *InfoStat
	SystemStart  *timestamppb.Timestamp
	ProcessStart *timestamppb.Timestamp
	Active       *bool
	// Only used in rendering host lists, not transferred over the wire.
	LastSeenAgo *string
	Latency     *string
	// contains filtered or unexported fields
}

func (Member_builder) Build added in v0.9.0 

func (b0 Member_builder) Build() *Member

type Members 

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

func MembersByID 

func MembersByID(id string) *Members

MembersByID returns a member from a supplied id.

func RecipientBySender 

func RecipientBySender(in *Member) *Members

RecipientBySender converts a Envelope.Sender to Envelope.Recipient.

func (*Members) GetCapability 

func (x *Members) GetCapability() []string

func (*Members) GetId 

func (x *Members) GetId() []string

func (*Members) GetName 

func (x *Members) GetName() []string

func (*Members) GetService 

func (x *Members) GetService() []string

func (*Members) GetTag 

func (x *Members) GetTag() []string

func (*Members) ProtoMessage 

func (*Members) ProtoMessage()

func (*Members) ProtoReflect 

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

func (*Members) Reset 

func (x *Members) Reset()

func (*Members) SetCapability added in v0.9.0 

func (x *Members) SetCapability(v []string)

func (*Members) SetId added in v0.9.0 

func (x *Members) SetId(v []string)

func (*Members) SetName added in v0.9.0 

func (x *Members) SetName(v []string)

func (*Members) SetService added in v0.9.0 

func (x *Members) SetService(v []string)

func (*Members) SetTag added in v0.9.0 

func (x *Members) SetTag(v []string)

func (*Members) String 

func (x *Members) String() string

type Members_builder added in v0.9.0 

type Members_builder struct {
	Id         []string
	Name       []string
	Capability []string
	Tag        []string
	Service    []string
	// contains filtered or unexported fields
}

func (Members_builder) Build added in v0.9.0 

func (b0 Members_builder) Build() *Members

type Message 

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

func (*Message) ClearEnvelope added in v0.9.0 

func (x *Message) ClearEnvelope()

func (*Message) ClearEventMessage added in v0.9.0 

func (x *Message) ClearEventMessage()

func (*Message) ClearMemberUpdateMessage added in v0.9.0 

func (x *Message) ClearMemberUpdateMessage()

func (*Message) ClearMessage added in v0.9.0 

func (x *Message) ClearMessage()

func (*Message) ClearPingMessage added in v0.9.0 

func (x *Message) ClearPingMessage()

func (*Message) ClearPongMessage added in v0.9.0 

func (x *Message) ClearPongMessage()

func (*Message) ClearRegisterMessage added in v0.9.0 

func (x *Message) ClearRegisterMessage()

func (*Message) ClearRepeatRegistrationMessage added in v0.9.0 

func (x *Message) ClearRepeatRegistrationMessage()

func (*Message) ClearTriggerAllMessage added in v0.9.0 

func (x *Message) ClearTriggerAllMessage()

func (*Message) GetEnvelope 

func (x *Message) GetEnvelope() *Envelope

func (*Message) GetEventMessage 

func (x *Message) GetEventMessage() *EventMessage

func (*Message) GetMemberUpdateMessage added in v0.5.0 

func (x *Message) GetMemberUpdateMessage() *MemberUpdateMessage

func (*Message) GetPingMessage 

func (x *Message) GetPingMessage() *PingMessage

func (*Message) GetPongMessage 

func (x *Message) GetPongMessage() *PongMessage

func (*Message) GetRegisterMessage 

func (x *Message) GetRegisterMessage() *RegisterMessage

func (*Message) GetRepeatRegistrationMessage added in v0.5.0 

func (x *Message) GetRepeatRegistrationMessage() *RepeatRegistrationMessage

func (*Message) GetTriggerAllMessage added in v0.5.0 

func (x *Message) GetTriggerAllMessage() *TriggerAllMessage

func (*Message) HasEnvelope added in v0.9.0 

func (x *Message) HasEnvelope() bool

func (*Message) HasEventMessage added in v0.9.0 

func (x *Message) HasEventMessage() bool

func (*Message) HasMemberUpdateMessage added in v0.9.0 

func (x *Message) HasMemberUpdateMessage() bool

func (*Message) HasMessage added in v0.9.0 

func (x *Message) HasMessage() bool

func (*Message) HasPingMessage added in v0.9.0 

func (x *Message) HasPingMessage() bool

func (*Message) HasPongMessage added in v0.9.0 

func (x *Message) HasPongMessage() bool

func (*Message) HasRegisterMessage added in v0.9.0 

func (x *Message) HasRegisterMessage() bool

func (*Message) HasRepeatRegistrationMessage added in v0.9.0 

func (x *Message) HasRepeatRegistrationMessage() bool

func (*Message) HasTriggerAllMessage added in v0.9.0 

func (x *Message) HasTriggerAllMessage() bool

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect 

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

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) SetEnvelope added in v0.9.0 

func (x *Message) SetEnvelope(v *Envelope)

func (*Message) SetEventMessage added in v0.9.0 

func (x *Message) SetEventMessage(v *EventMessage)

func (*Message) SetMemberUpdateMessage added in v0.9.0 

func (x *Message) SetMemberUpdateMessage(v *MemberUpdateMessage)

func (*Message) SetPingMessage added in v0.9.0 

func (x *Message) SetPingMessage(v *PingMessage)

func (*Message) SetPongMessage added in v0.9.0 

func (x *Message) SetPongMessage(v *PongMessage)

func (*Message) SetRegisterMessage added in v0.9.0 

func (x *Message) SetRegisterMessage(v *RegisterMessage)

func (*Message) SetRepeatRegistrationMessage added in v0.9.0 

func (x *Message) SetRepeatRegistrationMessage(v *RepeatRegistrationMessage)

func (*Message) SetTriggerAllMessage added in v0.9.0 

func (x *Message) SetTriggerAllMessage(v *TriggerAllMessage)

func (*Message) String 

func (x *Message) String() string

func (*Message) WhichMessage added in v0.9.0 

func (x *Message) WhichMessage() case_Message_Message

type Message_builder added in v0.9.0 

type Message_builder struct {
	Envelope *Envelope
	// Fields of oneof xxx_hidden_Message:
	RegisterMessage           *RegisterMessage
	PingMessage               *PingMessage
	PongMessage               *PongMessage
	EventMessage              *EventMessage
	TriggerAllMessage         *TriggerAllMessage
	RepeatRegistrationMessage *RepeatRegistrationMessage
	MemberUpdateMessage       *MemberUpdateMessage
	// contains filtered or unexported fields
}

func (Message_builder) Build added in v0.9.0 

func (b0 Message_builder) Build() *Message

type PingMessage 

type PingMessage struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (*PingMessage) ClearId added in v0.9.0 

func (x *PingMessage) ClearId()

func (*PingMessage) ClearStreamId added in v0.9.0 

func (x *PingMessage) ClearStreamId()

func (*PingMessage) ClearTs added in v0.9.0 

func (x *PingMessage) ClearTs()

func (*PingMessage) GetId 

func (x *PingMessage) GetId() string

func (*PingMessage) GetStreamId 

func (x *PingMessage) GetStreamId() string

func (*PingMessage) GetTs 

func (x *PingMessage) GetTs() *timestamppb.Timestamp

func (*PingMessage) HasId added in v0.9.0 

func (x *PingMessage) HasId() bool

func (*PingMessage) HasStreamId added in v0.9.0 

func (x *PingMessage) HasStreamId() bool

func (*PingMessage) HasTs added in v0.9.0 

func (x *PingMessage) HasTs() bool

func (*PingMessage) ProtoMessage 

func (*PingMessage) ProtoMessage()

func (*PingMessage) ProtoReflect 

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

func (*PingMessage) Reset 

func (x *PingMessage) Reset()

func (*PingMessage) SetId added in v0.9.0 

func (x *PingMessage) SetId(v string)

func (*PingMessage) SetStreamId added in v0.9.0 

func (x *PingMessage) SetStreamId(v string)

func (*PingMessage) SetTs added in v0.9.0 

func (x *PingMessage) SetTs(v *timestamppb.Timestamp)

func (*PingMessage) String 

func (x *PingMessage) String() string

type PingMessage_builder added in v0.9.0 

type PingMessage_builder struct {
	Id       *string
	StreamId *string
	Ts       *timestamppb.Timestamp
	// contains filtered or unexported fields
}

func (PingMessage_builder) Build added in v0.9.0 

func (b0 PingMessage_builder) Build() *PingMessage

type PongMessage 

type PongMessage struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (*PongMessage) ClearId added in v0.9.0 

func (x *PongMessage) ClearId()

func (*PongMessage) ClearStreamId added in v0.9.0 

func (x *PongMessage) ClearStreamId()

func (*PongMessage) ClearTs added in v0.9.0 

func (x *PongMessage) ClearTs()

func (*PongMessage) GetId 

func (x *PongMessage) GetId() string

func (*PongMessage) GetStreamId 

func (x *PongMessage) GetStreamId() string

func (*PongMessage) GetTs 

func (x *PongMessage) GetTs() *timestamppb.Timestamp

func (*PongMessage) HasId added in v0.9.0 

func (x *PongMessage) HasId() bool

func (*PongMessage) HasStreamId added in v0.9.0 

func (x *PongMessage) HasStreamId() bool

func (*PongMessage) HasTs added in v0.9.0 

func (x *PongMessage) HasTs() bool

func (*PongMessage) ProtoMessage 

func (*PongMessage) ProtoMessage()

func (*PongMessage) ProtoReflect 

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

func (*PongMessage) Reset 

func (x *PongMessage) Reset()

func (*PongMessage) SetId added in v0.9.0 

func (x *PongMessage) SetId(v string)

func (*PongMessage) SetStreamId added in v0.9.0 

func (x *PongMessage) SetStreamId(v string)

func (*PongMessage) SetTs added in v0.9.0 

func (x *PongMessage) SetTs(v *timestamppb.Timestamp)

func (*PongMessage) String 

func (x *PongMessage) String() string

type PongMessage_builder added in v0.9.0 

type PongMessage_builder struct {
	Id       *string
	StreamId *string
	Ts       *timestamppb.Timestamp
	// contains filtered or unexported fields
}

func (PongMessage_builder) Build added in v0.9.0 

func (b0 PongMessage_builder) Build() *PongMessage

type RSCAClient 

type RSCAClient interface {
	Pipe(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[Message, Message], error)
}

RSCAClient is the client API for RSCA service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewRSCAClient 

func NewRSCAClient(cc grpc.ClientConnInterface) RSCAClient

type RSCAServer 

type RSCAServer interface {
	Pipe(grpc.BidiStreamingServer[Message, Message]) error
}

RSCAServer is the server API for RSCA service. All implementations should embed UnimplementedRSCAServer for forward compatibility.

type RSCA_PipeClient 

type RSCA_PipeClient = grpc.BidiStreamingClient[Message, Message]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type RSCA_PipeServer 

type RSCA_PipeServer = grpc.BidiStreamingServer[Message, Message]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type RegisterMessage 

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

func (*RegisterMessage) ClearMember added in v0.9.0 

func (x *RegisterMessage) ClearMember()

func (*RegisterMessage) GetMember 

func (x *RegisterMessage) GetMember() *Member

func (*RegisterMessage) HasMember added in v0.9.0 

func (x *RegisterMessage) HasMember() bool

func (*RegisterMessage) ProtoMessage 

func (*RegisterMessage) ProtoMessage()

func (*RegisterMessage) ProtoReflect 

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

func (*RegisterMessage) Reset 

func (x *RegisterMessage) Reset()

func (*RegisterMessage) SetMember added in v0.9.0 

func (x *RegisterMessage) SetMember(v *Member)

func (*RegisterMessage) String 

func (x *RegisterMessage) String() string

type RegisterMessage_builder added in v0.9.0 

type RegisterMessage_builder struct {
	Member *Member
	// contains filtered or unexported fields
}

func (RegisterMessage_builder) Build added in v0.9.0 

func (b0 RegisterMessage_builder) Build() *RegisterMessage

type RemoveHostRequest added in v0.5.9 

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

func (*RemoveHostRequest) GetNames added in v0.5.9 

func (x *RemoveHostRequest) GetNames() []string

func (*RemoveHostRequest) ProtoMessage added in v0.5.9 

func (*RemoveHostRequest) ProtoMessage()

func (*RemoveHostRequest) ProtoReflect added in v0.5.9 

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

func (*RemoveHostRequest) Reset added in v0.5.9 

func (x *RemoveHostRequest) Reset()

func (*RemoveHostRequest) SetNames added in v0.9.0 

func (x *RemoveHostRequest) SetNames(v []string)

func (*RemoveHostRequest) String added in v0.5.9 

func (x *RemoveHostRequest) String() string

type RemoveHostRequest_builder added in v0.9.0 

type RemoveHostRequest_builder struct {
	Names []string
	// contains filtered or unexported fields
}

func (RemoveHostRequest_builder) Build added in v0.9.0 

func (b0 RemoveHostRequest_builder) Build() *RemoveHostRequest

type RemoveHostResponse added in v0.5.9 

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

func (*RemoveHostResponse) GetNames added in v0.5.9 

func (x *RemoveHostResponse) GetNames() []string

func (*RemoveHostResponse) ProtoMessage added in v0.5.9 

func (*RemoveHostResponse) ProtoMessage()

func (*RemoveHostResponse) ProtoReflect added in v0.5.9 

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

func (*RemoveHostResponse) Reset added in v0.5.9 

func (x *RemoveHostResponse) Reset()

func (*RemoveHostResponse) SetNames added in v0.9.0 

func (x *RemoveHostResponse) SetNames(v []string)

func (*RemoveHostResponse) String added in v0.5.9 

func (x *RemoveHostResponse) String() string

type RemoveHostResponse_builder added in v0.9.0 

type RemoveHostResponse_builder struct {
	Names []string
	// contains filtered or unexported fields
}

func (RemoveHostResponse_builder) Build added in v0.9.0 

func (b0 RemoveHostResponse_builder) Build() *RemoveHostResponse

type RepeatRegistrationMessage added in v0.5.0 

type RepeatRegistrationMessage struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (*RepeatRegistrationMessage) ClearId added in v0.9.0 

func (x *RepeatRegistrationMessage) ClearId()

func (*RepeatRegistrationMessage) GetId added in v0.5.0 

func (x *RepeatRegistrationMessage) GetId() string

func (*RepeatRegistrationMessage) HasId added in v0.9.0 

func (x *RepeatRegistrationMessage) HasId() bool

func (*RepeatRegistrationMessage) ProtoMessage added in v0.5.0 

func (*RepeatRegistrationMessage) ProtoMessage()

func (*RepeatRegistrationMessage) ProtoReflect added in v0.5.0 

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

func (*RepeatRegistrationMessage) Reset added in v0.5.0 

func (x *RepeatRegistrationMessage) Reset()

func (*RepeatRegistrationMessage) SetId added in v0.9.0 

func (x *RepeatRegistrationMessage) SetId(v string)

func (*RepeatRegistrationMessage) String added in v0.5.0 

func (x *RepeatRegistrationMessage) String() string

type RepeatRegistrationMessage_builder added in v0.9.0 

type RepeatRegistrationMessage_builder struct {
	Id *string
	// contains filtered or unexported fields
}

func (RepeatRegistrationMessage_builder) Build added in v0.9.0 

func (b0 RepeatRegistrationMessage_builder) Build() *RepeatRegistrationMessage

type Status 

type Status int32
const (
	Status_OK       Status = 0
	Status_WARNING  Status = 1
	Status_CRITICAL Status = 2
	Status_UNKNOWN  Status = 3
)

func ExitCodeToStatus 

func ExitCodeToStatus(exitCode int) Status

ExitCodeToStatus converts a returned exit code to a Status.

func (Status) Descriptor 

func (Status) Descriptor() protoreflect.EnumDescriptor

func (Status) Enum 

func (x Status) Enum() *Status

func (Status) Number 

func (x Status) Number() protoreflect.EnumNumber

func (Status) String 

func (x Status) String() string

func (Status) Type 

func (Status) Type() protoreflect.EnumType

type TriggerAllMessage added in v0.5.0 

type TriggerAllMessage struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (*TriggerAllMessage) ClearId added in v0.9.0 

func (x *TriggerAllMessage) ClearId()

func (*TriggerAllMessage) GetId added in v0.5.0 

func (x *TriggerAllMessage) GetId() string

func (*TriggerAllMessage) HasId added in v0.9.0 

func (x *TriggerAllMessage) HasId() bool

func (*TriggerAllMessage) ProtoMessage added in v0.5.0 

func (*TriggerAllMessage) ProtoMessage()

func (*TriggerAllMessage) ProtoReflect added in v0.5.0 

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

func (*TriggerAllMessage) Reset added in v0.5.0 

func (x *TriggerAllMessage) Reset()

func (*TriggerAllMessage) SetId added in v0.9.0 

func (x *TriggerAllMessage) SetId(v string)

func (*TriggerAllMessage) String added in v0.5.0 

func (x *TriggerAllMessage) String() string

type TriggerAllMessage_builder added in v0.9.0 

type TriggerAllMessage_builder struct {
	Id *string
	// contains filtered or unexported fields
}

func (TriggerAllMessage_builder) Build added in v0.9.0 

func (b0 TriggerAllMessage_builder) Build() *TriggerAllMessage

type TriggerAllResponse 

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

func (*TriggerAllResponse) GetNames 

func (x *TriggerAllResponse) GetNames() []string

func (*TriggerAllResponse) ProtoMessage 

func (*TriggerAllResponse) ProtoMessage()

func (*TriggerAllResponse) ProtoReflect 

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

func (*TriggerAllResponse) Reset 

func (x *TriggerAllResponse) Reset()

func (*TriggerAllResponse) SetNames added in v0.9.0 

func (x *TriggerAllResponse) SetNames(v []string)

func (*TriggerAllResponse) String 

func (x *TriggerAllResponse) String() string

type TriggerAllResponse_builder added in v0.9.0 

type TriggerAllResponse_builder struct {
	Names []string
	// contains filtered or unexported fields
}

func (TriggerAllResponse_builder) Build added in v0.9.0 

func (b0 TriggerAllResponse_builder) Build() *TriggerAllResponse

type TriggerInfoResponse added in v0.5.0 

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

func (*TriggerInfoResponse) GetNames added in v0.5.0 

func (x *TriggerInfoResponse) GetNames() []string

func (*TriggerInfoResponse) ProtoMessage added in v0.5.0 

func (*TriggerInfoResponse) ProtoMessage()

func (*TriggerInfoResponse) ProtoReflect added in v0.5.0 

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

func (*TriggerInfoResponse) Reset added in v0.5.0 

func (x *TriggerInfoResponse) Reset()

func (*TriggerInfoResponse) SetNames added in v0.9.0 

func (x *TriggerInfoResponse) SetNames(v []string)

func (*TriggerInfoResponse) String added in v0.5.0 

func (x *TriggerInfoResponse) String() string

type TriggerInfoResponse_builder added in v0.9.0 

type TriggerInfoResponse_builder struct {
	Names []string
	// contains filtered or unexported fields
}

func (TriggerInfoResponse_builder) Build added in v0.9.0 

func (b0 TriggerInfoResponse_builder) Build() *TriggerInfoResponse

type UnimplementedAdminServer 

type UnimplementedAdminServer struct{}

UnimplementedAdminServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedAdminServer) ListHosts 

func (UnimplementedAdminServer) ListHosts(*Empty, grpc.ServerStreamingServer[Member]) error

func (UnimplementedAdminServer) RemoveHost added in v0.5.9 

func (UnimplementedAdminServer) RemoveHost(context.Context, *RemoveHostRequest) (*RemoveHostResponse, error)

func (UnimplementedAdminServer) TriggerAll 

func (UnimplementedAdminServer) TriggerAll(context.Context, *Members) (*TriggerAllResponse, error)

func (UnimplementedAdminServer) TriggerInfo added in v0.5.0 

func (UnimplementedAdminServer) TriggerInfo(context.Context, *Members) (*TriggerInfoResponse, error)

type UnimplementedRSCAServer 

type UnimplementedRSCAServer struct{}

UnimplementedRSCAServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedRSCAServer) Pipe 

func (UnimplementedRSCAServer) Pipe(grpc.BidiStreamingServer[Message, Message]) error

type UnsafeAdminServer added in v0.5.6 

type UnsafeAdminServer interface {
	// contains filtered or unexported methods
}

UnsafeAdminServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AdminServer will result in compilation errors.

type UnsafeRSCAServer added in v0.5.6 

type UnsafeRSCAServer interface {
	// contains filtered or unexported methods
}

UnsafeRSCAServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RSCAServer will result in compilation errors.

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.