connect

type BootstrapConfigUpdated ¶

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

BootstrapConfigUpdated is sent when the bootstrap configuration has been updated. Bootstrap configuration is received via cluster API directly, and does not involve long running operations to construct it, like with a regular config.

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

func (*BootstrapConfigUpdated) ProtoMessage()

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

func (x *BootstrapConfigUpdated) Reset()

func (x *BootstrapConfigUpdated) String() string

type Config ¶

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

func NewConfig(endpoint string) (*Config, error)

func (c *Config) GetConnectionURI() string

func (c *Config) GetDialOptions() []grpc.DialOption

func (c *Config) GetDialTimeout() time.Duration

func (c *Config) RequireTLS() bool

type ConfigUpdated ¶

type ConfigUpdated struct {

	// version of the configuration changeset
	ChangesetVersion int64 `protobuf:"varint,1,opt,name=changeset_version,json=changesetVersion,proto3" json:"changeset_version,omitempty"`
	// contains filtered or unexported fields
}

ConfigUpdated is sent when the configuration has been updated for the connected Pomerium Core deployment

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

func (x *ConfigUpdated) GetChangesetVersion() int64

func (*ConfigUpdated) ProtoMessage()

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

func (x *ConfigUpdated) Reset()

func (x *ConfigUpdated) String() string

type ConnectClient ¶

type ConnectClient interface {
	// Subscribe is used to send a stream of messages from the Zero Cloud to the
	// Pomerium Core in managed mode.
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (Connect_SubscribeClient, error)
}

ConnectClient is the client API for Connect 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 NewAuthorizedConnectClient(
	ctx context.Context,
	endpoint string,
	tokenProvider TokenProviderFn,
) (ConnectClient, error)

func NewConnectClient(cc grpc.ClientConnInterface) ConnectClient

type ConnectServer ¶

type ConnectServer interface {
	// Subscribe is used to send a stream of messages from the Zero Cloud to the
	// Pomerium Core in managed mode.
	Subscribe(*SubscribeRequest, Connect_SubscribeServer) error
}

ConnectServer is the server API for Connect service. All implementations should embed UnimplementedConnectServer for forward compatibility

type Connect_SubscribeClient ¶

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

type Connect_SubscribeServer ¶

type Connect_SubscribeServer interface {
	Send(*Message) error
	grpc.ServerStream
}

type Message ¶

type Message struct {

	// Types that are assignable to Message:
	//
	//	*Message_ConfigUpdated
	//	*Message_BootstrapConfigUpdated
	Message isMessage_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

Message is an aggregate of all possible messages that can be sent from the cloud to the core in managed mode.

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

func (x *Message) GetBootstrapConfigUpdated() *BootstrapConfigUpdated

func (x *Message) GetConfigUpdated() *ConfigUpdated

func (m *Message) GetMessage() isMessage_Message

func (*Message) ProtoMessage()

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

func (x *Message) Reset()

func (x *Message) String() string

type Message_BootstrapConfigUpdated ¶

type Message_BootstrapConfigUpdated struct {
	BootstrapConfigUpdated *BootstrapConfigUpdated `protobuf:"bytes,2,opt,name=bootstrap_config_updated,json=bootstrapConfigUpdated,proto3,oneof"`
}

type Message_ConfigUpdated ¶

type Message_ConfigUpdated struct {
	ConfigUpdated *ConfigUpdated `protobuf:"bytes,1,opt,name=config_updated,json=configUpdated,proto3,oneof"`
}

type SubscribeRequest ¶

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

SubscribeRequest is used to subscribe to a stream of messages from the Zero Cloud to the Pomerium Core.

The Authorization: Bearer header must contain a valid token, that belongs to a cluster identity with appropriate claims set.

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

func (*SubscribeRequest) ProtoMessage()

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

func (x *SubscribeRequest) Reset()

func (x *SubscribeRequest) String() string

type TokenProviderFn ¶

type TokenProviderFn func(ctx context.Context, minTTL time.Duration) (string, error)

TokenProviderFn is a function that returns a token that is expected to be valid for at least minTTL

type UnimplementedConnectServer ¶

type UnimplementedConnectServer struct {
}

UnimplementedConnectServer should be embedded to have forward compatible implementations.

func (UnimplementedConnectServer) Subscribe(*SubscribeRequest, Connect_SubscribeServer) error

type UnsafeConnectServer ¶

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

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