notifier

package
v0.11.1 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterNotifierServer 

func RegisterNotifierServer(s *grpc.Server, srv NotifierServer)

Types

type BundleLoaded 

type BundleLoaded struct {
	Bundle               *common.Bundle `protobuf:"bytes,1,opt,name=bundle,proto3" json:"bundle,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*BundleLoaded) Descriptor 

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

func (*BundleLoaded) GetBundle 

func (m *BundleLoaded) GetBundle() *common.Bundle

func (*BundleLoaded) ProtoMessage 

func (*BundleLoaded) ProtoMessage()

func (*BundleLoaded) Reset 

func (m *BundleLoaded) Reset()

func (*BundleLoaded) String 

func (m *BundleLoaded) String() string

func (*BundleLoaded) XXX_DiscardUnknown 

func (m *BundleLoaded) XXX_DiscardUnknown()

func (*BundleLoaded) XXX_Marshal 

func (m *BundleLoaded) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BundleLoaded) XXX_Merge 

func (m *BundleLoaded) XXX_Merge(src proto.Message)

func (*BundleLoaded) XXX_Size 

func (m *BundleLoaded) XXX_Size() int

func (*BundleLoaded) XXX_Unmarshal 

func (m *BundleLoaded) XXX_Unmarshal(b []byte) error

type BundleUpdated 

type BundleUpdated struct {
	Bundle               *common.Bundle `protobuf:"bytes,1,opt,name=bundle,proto3" json:"bundle,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*BundleUpdated) Descriptor 

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

func (*BundleUpdated) GetBundle 

func (m *BundleUpdated) GetBundle() *common.Bundle

func (*BundleUpdated) ProtoMessage 

func (*BundleUpdated) ProtoMessage()

func (*BundleUpdated) Reset 

func (m *BundleUpdated) Reset()

func (*BundleUpdated) String 

func (m *BundleUpdated) String() string

func (*BundleUpdated) XXX_DiscardUnknown 

func (m *BundleUpdated) XXX_DiscardUnknown()

func (*BundleUpdated) XXX_Marshal 

func (m *BundleUpdated) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BundleUpdated) XXX_Merge 

func (m *BundleUpdated) XXX_Merge(src proto.Message)

func (*BundleUpdated) XXX_Size 

func (m *BundleUpdated) XXX_Size() int

func (*BundleUpdated) XXX_Unmarshal 

func (m *BundleUpdated) XXX_Unmarshal(b []byte) error

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)
	Configure(ctx context.Context, in *plugin.ConfigureRequest, opts ...grpc.CallOption) (*plugin.ConfigureResponse, error)
	GetPluginInfo(ctx context.Context, in *plugin.GetPluginInfoRequest, opts ...grpc.CallOption) (*plugin.GetPluginInfoResponse, error)
}

NotifierClient is the client API for Notifier service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewNotifierClient 

func NewNotifierClient(cc grpc.ClientConnInterface) NotifierClient

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)
	Configure(context.Context, *plugin.ConfigureRequest) (*plugin.ConfigureResponse, error)
	GetPluginInfo(context.Context, *plugin.GetPluginInfoRequest) (*plugin.GetPluginInfoResponse, error)
}

NotifierServer is the server API for Notifier service.

type NotifyAndAdviseRequest 

type NotifyAndAdviseRequest struct {
	// Types that are valid to be assigned to Event:
	//	*NotifyAndAdviseRequest_BundleLoaded
	Event                isNotifyAndAdviseRequest_Event `protobuf_oneof:"event"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*NotifyAndAdviseRequest) Descriptor 

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

func (*NotifyAndAdviseRequest) GetBundleLoaded 

func (m *NotifyAndAdviseRequest) GetBundleLoaded() *BundleLoaded

func (*NotifyAndAdviseRequest) GetEvent 

func (m *NotifyAndAdviseRequest) GetEvent() isNotifyAndAdviseRequest_Event

func (*NotifyAndAdviseRequest) ProtoMessage 

func (*NotifyAndAdviseRequest) ProtoMessage()

func (*NotifyAndAdviseRequest) Reset 

func (m *NotifyAndAdviseRequest) Reset()

func (*NotifyAndAdviseRequest) String 

func (m *NotifyAndAdviseRequest) String() string

func (*NotifyAndAdviseRequest) XXX_DiscardUnknown 

func (m *NotifyAndAdviseRequest) XXX_DiscardUnknown()

func (*NotifyAndAdviseRequest) XXX_Marshal 

func (m *NotifyAndAdviseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NotifyAndAdviseRequest) XXX_Merge 

func (m *NotifyAndAdviseRequest) XXX_Merge(src proto.Message)

func (*NotifyAndAdviseRequest) XXX_OneofWrappers 

func (*NotifyAndAdviseRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*NotifyAndAdviseRequest) XXX_Size 

func (m *NotifyAndAdviseRequest) XXX_Size() int

func (*NotifyAndAdviseRequest) XXX_Unmarshal 

func (m *NotifyAndAdviseRequest) XXX_Unmarshal(b []byte) error

type NotifyAndAdviseRequest_BundleLoaded 

type NotifyAndAdviseRequest_BundleLoaded struct {
	BundleLoaded *BundleLoaded `protobuf:"bytes,1,opt,name=bundle_loaded,json=bundleLoaded,proto3,oneof"`
}

type NotifyAndAdviseResponse 

type NotifyAndAdviseResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NotifyAndAdviseResponse) Descriptor 

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

func (*NotifyAndAdviseResponse) ProtoMessage 

func (*NotifyAndAdviseResponse) ProtoMessage()

func (*NotifyAndAdviseResponse) Reset 

func (m *NotifyAndAdviseResponse) Reset()

func (*NotifyAndAdviseResponse) String 

func (m *NotifyAndAdviseResponse) String() string

func (*NotifyAndAdviseResponse) XXX_DiscardUnknown 

func (m *NotifyAndAdviseResponse) XXX_DiscardUnknown()

func (*NotifyAndAdviseResponse) XXX_Marshal 

func (m *NotifyAndAdviseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NotifyAndAdviseResponse) XXX_Merge 

func (m *NotifyAndAdviseResponse) XXX_Merge(src proto.Message)

func (*NotifyAndAdviseResponse) XXX_Size 

func (m *NotifyAndAdviseResponse) XXX_Size() int

func (*NotifyAndAdviseResponse) XXX_Unmarshal 

func (m *NotifyAndAdviseResponse) XXX_Unmarshal(b []byte) error

type NotifyRequest 

type NotifyRequest struct {
	// Types that are valid to be assigned to Event:
	//	*NotifyRequest_BundleUpdated
	Event                isNotifyRequest_Event `protobuf_oneof:"event"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*NotifyRequest) Descriptor 

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

func (*NotifyRequest) GetBundleUpdated 

func (m *NotifyRequest) GetBundleUpdated() *BundleUpdated

func (*NotifyRequest) GetEvent 

func (m *NotifyRequest) GetEvent() isNotifyRequest_Event

func (*NotifyRequest) ProtoMessage 

func (*NotifyRequest) ProtoMessage()

func (*NotifyRequest) Reset 

func (m *NotifyRequest) Reset()

func (*NotifyRequest) String 

func (m *NotifyRequest) String() string

func (*NotifyRequest) XXX_DiscardUnknown 

func (m *NotifyRequest) XXX_DiscardUnknown()

func (*NotifyRequest) XXX_Marshal 

func (m *NotifyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NotifyRequest) XXX_Merge 

func (m *NotifyRequest) XXX_Merge(src proto.Message)

func (*NotifyRequest) XXX_OneofWrappers 

func (*NotifyRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*NotifyRequest) XXX_Size 

func (m *NotifyRequest) XXX_Size() int

func (*NotifyRequest) XXX_Unmarshal 

func (m *NotifyRequest) XXX_Unmarshal(b []byte) error

type NotifyRequest_BundleUpdated 

type NotifyRequest_BundleUpdated struct {
	BundleUpdated *BundleUpdated `protobuf:"bytes,1,opt,name=bundle_updated,json=bundleUpdated,proto3,oneof"`
}

type NotifyResponse 

type NotifyResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NotifyResponse) Descriptor 

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

func (*NotifyResponse) ProtoMessage 

func (*NotifyResponse) ProtoMessage()

func (*NotifyResponse) Reset 

func (m *NotifyResponse) Reset()

func (*NotifyResponse) String 

func (m *NotifyResponse) String() string

func (*NotifyResponse) XXX_DiscardUnknown 

func (m *NotifyResponse) XXX_DiscardUnknown()

func (*NotifyResponse) XXX_Marshal 

func (m *NotifyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NotifyResponse) XXX_Merge 

func (m *NotifyResponse) XXX_Merge(src proto.Message)

func (*NotifyResponse) XXX_Size 

func (m *NotifyResponse) XXX_Size() int

func (*NotifyResponse) XXX_Unmarshal 

func (m *NotifyResponse) XXX_Unmarshal(b []byte) error

type UnimplementedNotifierServer 

type UnimplementedNotifierServer struct {
}

UnimplementedNotifierServer can be embedded to have forward compatible implementations.

func (*UnimplementedNotifierServer) Configure 

func (*UnimplementedNotifierServer) Configure(ctx context.Context, req *plugin.ConfigureRequest) (*plugin.ConfigureResponse, error)

func (*UnimplementedNotifierServer) GetPluginInfo 

func (*UnimplementedNotifierServer) GetPluginInfo(ctx context.Context, req *plugin.GetPluginInfoRequest) (*plugin.GetPluginInfoResponse, error)

func (*UnimplementedNotifierServer) Notify 

func (*UnimplementedNotifierServer) Notify(ctx context.Context, req *NotifyRequest) (*NotifyResponse, error)

func (*UnimplementedNotifierServer) NotifyAndAdvise 

func (*UnimplementedNotifierServer) NotifyAndAdvise(ctx context.Context, req *NotifyAndAdviseRequest) (*NotifyAndAdviseResponse, 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.