notifierv1

package
v1.9.4 Latest Latest
Warning

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

Go to latest
Published: Aug 16, 2023 License: Apache-2.0 Imports: 10 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_spire_plugin_server_notifier_v1_notifier_proto protoreflect.FileDescriptor
View Source
var Notifier_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "spire.plugin.server.notifier.v1.Notifier",
	HandlerType: (*NotifierServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Notify",
			Handler:    _Notifier_Notify_Handler,
		},
		{
			MethodName: "NotifyAndAdvise",
			Handler:    _Notifier_NotifyAndAdvise_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "spire/plugin/server/notifier/v1/notifier.proto",
}

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

Functions

func NotifierPluginServer

func NotifierPluginServer(server NotifierServer) pluginsdk.PluginServer

func RegisterNotifierServer

func RegisterNotifierServer(s grpc.ServiceRegistrar, srv NotifierServer)

Types

type BundleLoaded

type BundleLoaded struct {

	// Required. The bundle that was loaded.
	Bundle *types.Bundle `protobuf:"bytes,1,opt,name=bundle,proto3" json:"bundle,omitempty"`
	// contains filtered or unexported fields
}

func (*BundleLoaded) Descriptor deprecated

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

Deprecated: Use BundleLoaded.ProtoReflect.Descriptor instead.

func (*BundleLoaded) GetBundle

func (x *BundleLoaded) GetBundle() *types.Bundle

func (*BundleLoaded) ProtoMessage

func (*BundleLoaded) ProtoMessage()

func (*BundleLoaded) ProtoReflect

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

func (*BundleLoaded) Reset

func (x *BundleLoaded) Reset()

func (*BundleLoaded) String

func (x *BundleLoaded) String() string

type BundleUpdated

type BundleUpdated struct {

	// Required. The bundle that was updated.
	Bundle *types.Bundle `protobuf:"bytes,1,opt,name=bundle,proto3" json:"bundle,omitempty"`
	// contains filtered or unexported fields
}

func (*BundleUpdated) Descriptor deprecated

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

Deprecated: Use BundleUpdated.ProtoReflect.Descriptor instead.

func (*BundleUpdated) GetBundle

func (x *BundleUpdated) GetBundle() *types.Bundle

func (*BundleUpdated) ProtoMessage

func (*BundleUpdated) ProtoMessage()

func (*BundleUpdated) ProtoReflect

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

func (*BundleUpdated) Reset

func (x *BundleUpdated) Reset()

func (*BundleUpdated) String

func (x *BundleUpdated) String() string

type NotifierClient

type NotifierClient interface {
	// Notify notifies the plugin that an event occurred. Errors returned by
	// the plugin are logged but otherwise ignored.
	Notify(ctx context.Context, in *NotifyRequest, opts ...grpc.CallOption) (*NotifyResponse, error)
	// NotifyAndAdvise notifies the plugin that an event occurred and waits
	// for a response. Errors returned by the plugin control SPIRE Server
	// behavior. See NotifyAndAdviseRequest for per-event details.
	NotifyAndAdvise(ctx context.Context, in *NotifyAndAdviseRequest, opts ...grpc.CallOption) (*NotifyAndAdviseResponse, error)
}

NotifierClient is the client API for Notifier 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 NewNotifierClient

func NewNotifierClient(cc grpc.ClientConnInterface) NotifierClient

type NotifierPluginClient

type NotifierPluginClient struct {
	NotifierClient
}

func (*NotifierPluginClient) GRPCServiceName

func (c *NotifierPluginClient) GRPCServiceName() string

func (*NotifierPluginClient) InitClient

func (c *NotifierPluginClient) InitClient(conn grpc.ClientConnInterface) interface{}

func (*NotifierPluginClient) IsInitialized

func (c *NotifierPluginClient) IsInitialized() bool

func (NotifierPluginClient) Type

func (s NotifierPluginClient) Type() string

type NotifierServer

type NotifierServer interface {
	// Notify notifies the plugin that an event occurred. Errors returned by
	// the plugin are logged but otherwise ignored.
	Notify(context.Context, *NotifyRequest) (*NotifyResponse, error)
	// NotifyAndAdvise notifies the plugin that an event occurred and waits
	// for a response. Errors returned by the plugin control SPIRE Server
	// behavior. See NotifyAndAdviseRequest for per-event details.
	NotifyAndAdvise(context.Context, *NotifyAndAdviseRequest) (*NotifyAndAdviseResponse, error)
	// contains filtered or unexported methods
}

NotifierServer is the server API for Notifier service. All implementations must embed UnimplementedNotifierServer for forward compatibility

type NotifyAndAdviseRequest

type NotifyAndAdviseRequest struct {

	// Required. The event the plugin is being notified for.
	//
	// Types that are assignable to Event:
	//	*NotifyAndAdviseRequest_BundleLoaded
	Event isNotifyAndAdviseRequest_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

func (*NotifyAndAdviseRequest) Descriptor deprecated

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

Deprecated: Use NotifyAndAdviseRequest.ProtoReflect.Descriptor instead.

func (*NotifyAndAdviseRequest) GetBundleLoaded

func (x *NotifyAndAdviseRequest) GetBundleLoaded() *BundleLoaded

func (*NotifyAndAdviseRequest) GetEvent

func (m *NotifyAndAdviseRequest) GetEvent() isNotifyAndAdviseRequest_Event

func (*NotifyAndAdviseRequest) ProtoMessage

func (*NotifyAndAdviseRequest) ProtoMessage()

func (*NotifyAndAdviseRequest) ProtoReflect

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

func (*NotifyAndAdviseRequest) Reset

func (x *NotifyAndAdviseRequest) Reset()

func (*NotifyAndAdviseRequest) String

func (x *NotifyAndAdviseRequest) String() string

type NotifyAndAdviseRequest_BundleLoaded

type NotifyAndAdviseRequest_BundleLoaded struct {
	// BundleLoaded is emitted on startup after SPIRE Server creates/loads
	// the trust bundle. If an error is returned SPIRE Server is shut down.
	BundleLoaded *BundleLoaded `protobuf:"bytes,1,opt,name=bundle_loaded,json=bundleLoaded,proto3,oneof"`
}

type NotifyAndAdviseResponse

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

func (*NotifyAndAdviseResponse) Descriptor deprecated

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

Deprecated: Use NotifyAndAdviseResponse.ProtoReflect.Descriptor instead.

func (*NotifyAndAdviseResponse) ProtoMessage

func (*NotifyAndAdviseResponse) ProtoMessage()

func (*NotifyAndAdviseResponse) ProtoReflect

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

func (*NotifyAndAdviseResponse) Reset

func (x *NotifyAndAdviseResponse) Reset()

func (*NotifyAndAdviseResponse) String

func (x *NotifyAndAdviseResponse) String() string

type NotifyRequest

type NotifyRequest struct {

	// Required. The event the plugin is being notified for.
	//
	// Types that are assignable to Event:
	//	*NotifyRequest_BundleUpdated
	Event isNotifyRequest_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

func (*NotifyRequest) Descriptor deprecated

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

Deprecated: Use NotifyRequest.ProtoReflect.Descriptor instead.

func (*NotifyRequest) GetBundleUpdated

func (x *NotifyRequest) GetBundleUpdated() *BundleUpdated

func (*NotifyRequest) GetEvent

func (m *NotifyRequest) GetEvent() isNotifyRequest_Event

func (*NotifyRequest) ProtoMessage

func (*NotifyRequest) ProtoMessage()

func (*NotifyRequest) ProtoReflect

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

func (*NotifyRequest) Reset

func (x *NotifyRequest) Reset()

func (*NotifyRequest) String

func (x *NotifyRequest) String() string

type NotifyRequest_BundleUpdated

type NotifyRequest_BundleUpdated struct {
	// BundleUpdated is emitted whenever SPIRE Server changes the trust
	// bundle.
	BundleUpdated *BundleUpdated `protobuf:"bytes,1,opt,name=bundle_updated,json=bundleUpdated,proto3,oneof"`
}

type NotifyResponse

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

func (*NotifyResponse) Descriptor deprecated

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

Deprecated: Use NotifyResponse.ProtoReflect.Descriptor instead.

func (*NotifyResponse) ProtoMessage

func (*NotifyResponse) ProtoMessage()

func (*NotifyResponse) ProtoReflect

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

func (*NotifyResponse) Reset

func (x *NotifyResponse) Reset()

func (*NotifyResponse) String

func (x *NotifyResponse) String() string

type UnimplementedNotifierServer

type UnimplementedNotifierServer struct {
}

UnimplementedNotifierServer must be embedded to have forward compatible implementations.

func (UnimplementedNotifierServer) Notify

func (UnimplementedNotifierServer) NotifyAndAdvise

type UnsafeNotifierServer

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL