api

package
v0.8.1 Latest Latest
Warning

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

 Go to latest Published: Feb 13, 2024 License: GPL-3.0 Imports: 14 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 (
	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) (Admin_ListHostsClient, 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, Admin_ListHostsServer) 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 interface {
	Recv() (*Member, error)
	grpc.ClientStream
}

type Admin_ListHostsServer 

type Admin_ListHostsServer interface {
	Send(*Member) error
	grpc.ServerStream
}

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) EnumDescriptor deprecated 

func (CheckType) EnumDescriptor() ([]byte, []int)

Deprecated: Use CheckType.Descriptor instead.

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) Descriptor deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

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 Envelope 

type Envelope struct {
	Sender    *Member  `protobuf:"bytes,10,opt,name=sender,proto3" json:"sender,omitempty"`
	Recipient *Members `protobuf:"bytes,11,opt,name=recipient,proto3" json:"recipient,omitempty"`
	// contains filtered or unexported fields
}

func (*Envelope) Descriptor deprecated 

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

Deprecated: Use Envelope.ProtoReflect.Descriptor instead.

func (*Envelope) GetRecipient 

func (x *Envelope) GetRecipient() *Members

func (*Envelope) GetSender 

func (x *Envelope) GetSender() *Member

func (*Envelope) ProtoMessage 

func (*Envelope) ProtoMessage()

func (*Envelope) ProtoReflect 

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

func (*Envelope) Reset 

func (x *Envelope) Reset()

func (*Envelope) String 

func (x *Envelope) String() string

type EventMessage 

type EventMessage struct {
	Hostname         string                 `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Type             CheckType              `protobuf:"varint,2,opt,name=type,proto3,enum=rsca.api.CheckType" json:"type,omitempty"`
	Check            string                 `protobuf:"bytes,3,opt,name=check,proto3" json:"check,omitempty"`
	Status           Status                 `protobuf:"varint,4,opt,name=status,proto3,enum=rsca.api.Status" json:"status,omitempty"`
	Output           string                 `protobuf:"bytes,5,opt,name=output,proto3" json:"output,omitempty"`
	OutputError      string                 `protobuf:"bytes,10,opt,name=output_error,json=outputError,proto3" json:"output_error,omitempty"`
	Perfdata         string                 `protobuf:"bytes,6,opt,name=perfdata,proto3" json:"perfdata,omitempty"`
	RequestTimestamp *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=request_timestamp,json=requestTimestamp,proto3" json:"request_timestamp,omitempty"`
	Retries          int32                  `protobuf:"varint,8,opt,name=retries,proto3" json:"retries,omitempty"`
	Id               string                 `protobuf:"bytes,9,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*EventMessage) Descriptor deprecated 

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

Deprecated: Use EventMessage.ProtoReflect.Descriptor instead.

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) ProtoMessage 

func (*EventMessage) ProtoMessage()

func (*EventMessage) ProtoReflect 

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

func (*EventMessage) Reset 

func (x *EventMessage) Reset()

func (*EventMessage) String 

func (x *EventMessage) String() string

type InfoStat added in v0.5.0 

type InfoStat struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Hostname  string                 `protobuf:"bytes,21,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Uptime    uint64                 `protobuf:"varint,22,opt,name=uptime,proto3" json:"uptime,omitempty"`
	BootTime  uint64                 `protobuf:"varint,23,opt,name=boot_time,json=bootTime,proto3" json:"boot_time,omitempty"`
	// number of processes
	Procs uint64 `protobuf:"varint,24,opt,name=procs,proto3" json:"procs,omitempty"`
	// ex: freebsd, linux
	Os string `protobuf:"bytes,25,opt,name=os,proto3" json:"os,omitempty"`
	// ex: ubuntu, linuxmint
	Platform string `protobuf:"bytes,26,opt,name=platform,proto3" json:"platform,omitempty"`
	// ex: debian, rhel
	PlatformFamily string `protobuf:"bytes,27,opt,name=platform_family,json=platformFamily,proto3" json:"platform_family,omitempty"`
	// version of the complete OS
	PlatformVersion string `protobuf:"bytes,28,opt,name=platform_version,json=platformVersion,proto3" json:"platform_version,omitempty"`
	// version of the OS kernel (if available)
	KernelVersion string `protobuf:"bytes,29,opt,name=kernel_version,json=kernelVersion,proto3" json:"kernel_version,omitempty"`
	// native cpu architecture queried at runtime, as returned by `uname -m` or empty string in case of error
	KernelArch string `protobuf:"bytes,30,opt,name=kernel_arch,json=kernelArch,proto3" json:"kernel_arch,omitempty"`
	VirtSystem string `protobuf:"bytes,31,opt,name=virt_system,json=virtSystem,proto3" json:"virt_system,omitempty"`
	// guest or host
	VirtRole string `protobuf:"bytes,32,opt,name=virt_role,json=virtRole,proto3" json:"virt_role,omitempty"`
	// ex: uuid
	HostId string `protobuf:"bytes,33,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	// 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) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use InfoStat.ProtoReflect.Descriptor instead.

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) 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) String added in v0.5.0 

func (x *InfoStat) String() string

type Member 

type Member struct {
	Id           string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	InternalId   string                 `protobuf:"bytes,2,opt,name=internal_id,json=internalId,proto3" json:"internal_id,omitempty"`
	Name         string                 `protobuf:"bytes,10,opt,name=name,proto3" json:"name,omitempty"`
	Capability   []string               `protobuf:"bytes,11,rep,name=capability,proto3" json:"capability,omitempty"`
	Tag          []string               `protobuf:"bytes,12,rep,name=tag,proto3" json:"tag,omitempty"`
	Service      []string               `protobuf:"bytes,13,rep,name=service,proto3" json:"service,omitempty"`
	Version      string                 `protobuf:"bytes,90,opt,name=version,proto3" json:"version,omitempty"`
	GitHash      string                 `protobuf:"bytes,91,opt,name=git_hash,json=gitHash,proto3" json:"git_hash,omitempty"`
	BuildDate    string                 `protobuf:"bytes,92,opt,name=build_date,json=buildDate,proto3" json:"build_date,omitempty"`
	LastSeen     *timestamppb.Timestamp `protobuf:"bytes,100,opt,name=last_seen,json=lastSeen,proto3" json:"last_seen,omitempty"`
	PingLatency  *durationpb.Duration   `protobuf:"bytes,102,opt,name=ping_latency,json=pingLatency,proto3" json:"ping_latency,omitempty"`
	InfoStat     *InfoStat              `protobuf:"bytes,200,opt,name=info_stat,json=infoStat,proto3" json:"info_stat,omitempty"`
	SystemStart  *timestamppb.Timestamp `protobuf:"bytes,201,opt,name=system_start,json=systemStart,proto3" json:"system_start,omitempty"`
	ProcessStart *timestamppb.Timestamp `protobuf:"bytes,202,opt,name=process_start,json=processStart,proto3" json:"process_start,omitempty"`
	Active       bool                   `protobuf:"varint,203,opt,name=active,proto3" json:"active,omitempty"`
	// Only used in rendering host lists, not transferred over the wire.
	LastSeenAgo string `protobuf:"bytes,1001,opt,name=last_seen_ago,json=lastSeenAgo,proto3" json:"last_seen_ago,omitempty"`
	Latency     string `protobuf:"bytes,1003,opt,name=latency,proto3" json:"latency,omitempty"`
	// contains filtered or unexported fields
}

func (*Member) Descriptor deprecated 

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

Deprecated: Use Member.ProtoReflect.Descriptor instead.

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) 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) String 

func (x *Member) String() string

type MemberUpdateMessage added in v0.5.0 

type MemberUpdateMessage struct {
	Member *Member `protobuf:"bytes,1,opt,name=member,proto3" json:"member,omitempty"`
	// contains filtered or unexported fields
}

func (*MemberUpdateMessage) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use MemberUpdateMessage.ProtoReflect.Descriptor instead.

func (*MemberUpdateMessage) GetMember added in v0.5.0 

func (x *MemberUpdateMessage) GetMember() *Member

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) String added in v0.5.0 

func (x *MemberUpdateMessage) String() string

type Members 

type Members struct {
	Id         []string `protobuf:"bytes,10,rep,name=id,proto3" json:"id,omitempty"`
	Name       []string `protobuf:"bytes,11,rep,name=name,proto3" json:"name,omitempty"`
	Capability []string `protobuf:"bytes,12,rep,name=capability,proto3" json:"capability,omitempty"`
	Tag        []string `protobuf:"bytes,13,rep,name=tag,proto3" json:"tag,omitempty"`
	Service    []string `protobuf:"bytes,14,rep,name=service,proto3" json:"service,omitempty"`
	// 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) Descriptor deprecated 

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

Deprecated: Use Members.ProtoReflect.Descriptor instead.

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) String 

func (x *Members) String() string

type Message 

type Message struct {
	Envelope *Envelope `protobuf:"bytes,1,opt,name=envelope,proto3" json:"envelope,omitempty"`
	// Types that are assignable to Message:
	//
	//	*Message_RegisterMessage
	//	*Message_PingMessage
	//	*Message_PongMessage
	//	*Message_EventMessage
	//	*Message_TriggerAllMessage
	//	*Message_RepeatRegistrationMessage
	//	*Message_MemberUpdateMessage
	Message isMessage_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor deprecated 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

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) GetMessage 

func (m *Message) GetMessage() isMessage_Message

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) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect 

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

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) String 

func (x *Message) String() string

type Message_EventMessage 

type Message_EventMessage struct {
	EventMessage *EventMessage `protobuf:"bytes,103,opt,name=event_message,json=eventMessage,proto3,oneof"`
}

type Message_MemberUpdateMessage added in v0.5.0 

type Message_MemberUpdateMessage struct {
	MemberUpdateMessage *MemberUpdateMessage `protobuf:"bytes,106,opt,name=member_update_message,json=memberUpdateMessage,proto3,oneof"`
}

type Message_PingMessage 

type Message_PingMessage struct {
	PingMessage *PingMessage `protobuf:"bytes,101,opt,name=ping_message,json=pingMessage,proto3,oneof"`
}

type Message_PongMessage 

type Message_PongMessage struct {
	PongMessage *PongMessage `protobuf:"bytes,102,opt,name=pong_message,json=pongMessage,proto3,oneof"`
}

type Message_RegisterMessage 

type Message_RegisterMessage struct {
	RegisterMessage *RegisterMessage `protobuf:"bytes,100,opt,name=register_message,json=registerMessage,proto3,oneof"`
}

type Message_RepeatRegistrationMessage added in v0.5.0 

type Message_RepeatRegistrationMessage struct {
	RepeatRegistrationMessage *RepeatRegistrationMessage `protobuf:"bytes,105,opt,name=repeat_registration_message,json=repeatRegistrationMessage,proto3,oneof"`
}

type Message_TriggerAllMessage added in v0.5.0 

type Message_TriggerAllMessage struct {
	TriggerAllMessage *TriggerAllMessage `protobuf:"bytes,104,opt,name=trigger_all_message,json=triggerAllMessage,proto3,oneof"`
}

type PingMessage 

type PingMessage struct {
	Id       string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	StreamId string                 `protobuf:"bytes,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Ts       *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=ts,proto3" json:"ts,omitempty"`
	// contains filtered or unexported fields
}

func (*PingMessage) Descriptor deprecated 

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

Deprecated: Use PingMessage.ProtoReflect.Descriptor instead.

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) ProtoMessage 

func (*PingMessage) ProtoMessage()

func (*PingMessage) ProtoReflect 

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

func (*PingMessage) Reset 

func (x *PingMessage) Reset()

func (*PingMessage) String 

func (x *PingMessage) String() string

type PongMessage 

type PongMessage struct {
	Id       string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	StreamId string                 `protobuf:"bytes,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Ts       *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=ts,proto3" json:"ts,omitempty"`
	// contains filtered or unexported fields
}

func (*PongMessage) Descriptor deprecated 

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

Deprecated: Use PongMessage.ProtoReflect.Descriptor instead.

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) ProtoMessage 

func (*PongMessage) ProtoMessage()

func (*PongMessage) ProtoReflect 

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

func (*PongMessage) Reset 

func (x *PongMessage) Reset()

func (*PongMessage) String 

func (x *PongMessage) String() string

type RSCAClient 

type RSCAClient interface {
	Pipe(ctx context.Context, opts ...grpc.CallOption) (RSCA_PipeClient, 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(RSCA_PipeServer) error
}

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

type RSCA_PipeClient 

type RSCA_PipeClient interface {
	Send(*Message) error
	Recv() (*Message, error)
	grpc.ClientStream
}

type RSCA_PipeServer 

type RSCA_PipeServer interface {
	Send(*Message) error
	Recv() (*Message, error)
	grpc.ServerStream
}

type RegisterMessage 

type RegisterMessage struct {
	Member *Member `protobuf:"bytes,1,opt,name=member,proto3" json:"member,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterMessage) Descriptor deprecated 

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

Deprecated: Use RegisterMessage.ProtoReflect.Descriptor instead.

func (*RegisterMessage) GetMember 

func (x *RegisterMessage) GetMember() *Member

func (*RegisterMessage) ProtoMessage 

func (*RegisterMessage) ProtoMessage()

func (*RegisterMessage) ProtoReflect 

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

func (*RegisterMessage) Reset 

func (x *RegisterMessage) Reset()

func (*RegisterMessage) String 

func (x *RegisterMessage) String() string

type RemoveHostRequest added in v0.5.9 

type RemoveHostRequest struct {
	Names []string `protobuf:"bytes,1,rep,name=names,proto3" json:"names,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveHostRequest) Descriptor deprecated added in v0.5.9 

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

Deprecated: Use RemoveHostRequest.ProtoReflect.Descriptor instead.

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) String added in v0.5.9 

func (x *RemoveHostRequest) String() string

type RemoveHostResponse added in v0.5.9 

type RemoveHostResponse struct {
	Names []string `protobuf:"bytes,1,rep,name=names,proto3" json:"names,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveHostResponse) Descriptor deprecated added in v0.5.9 

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

Deprecated: Use RemoveHostResponse.ProtoReflect.Descriptor instead.

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) String added in v0.5.9 

func (x *RemoveHostResponse) String() string

type RepeatRegistrationMessage added in v0.5.0 

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

func (*RepeatRegistrationMessage) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use RepeatRegistrationMessage.ProtoReflect.Descriptor instead.

func (*RepeatRegistrationMessage) GetId added in v0.5.0 

func (x *RepeatRegistrationMessage) GetId() string

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) String added in v0.5.0 

func (x *RepeatRegistrationMessage) String() string

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) EnumDescriptor deprecated 

func (Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use Status.Descriptor instead.

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 {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*TriggerAllMessage) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use TriggerAllMessage.ProtoReflect.Descriptor instead.

func (*TriggerAllMessage) GetId added in v0.5.0 

func (x *TriggerAllMessage) GetId() string

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) String added in v0.5.0 

func (x *TriggerAllMessage) String() string

type TriggerAllResponse 

type TriggerAllResponse struct {
	Names []string `protobuf:"bytes,1,rep,name=names,proto3" json:"names,omitempty"`
	// contains filtered or unexported fields
}

func (*TriggerAllResponse) Descriptor deprecated 

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

Deprecated: Use TriggerAllResponse.ProtoReflect.Descriptor instead.

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) String 

func (x *TriggerAllResponse) String() string

type TriggerInfoResponse added in v0.5.0 

type TriggerInfoResponse struct {
	Names []string `protobuf:"bytes,1,rep,name=names,proto3" json:"names,omitempty"`
	// contains filtered or unexported fields
}

func (*TriggerInfoResponse) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use TriggerInfoResponse.ProtoReflect.Descriptor instead.

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) String added in v0.5.0 

func (x *TriggerInfoResponse) String() string

type UnimplementedAdminServer 

type UnimplementedAdminServer struct {
}

UnimplementedAdminServer should be embedded to have forward compatible implementations.

func (UnimplementedAdminServer) ListHosts 

func (UnimplementedAdminServer) ListHosts(*Empty, Admin_ListHostsServer) 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.

func (UnimplementedRSCAServer) Pipe 

func (UnimplementedRSCAServer) Pipe(RSCA_PipeServer) 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.