api

package
v0.9.1 Latest Latest
Warning

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

 Go to latest Published: Oct 17, 2024 License: MIT Imports: 18 Imported by: 0

Documentation

Overview

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var File_hammer_proto protoreflect.FileDescriptor

Functions

func RegisterHammerHandler 

func RegisterHammerHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterHammerHandler registers the http handlers for service Hammer to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterHammerHandlerClient 

func RegisterHammerHandlerClient(ctx context.Context, mux *runtime.ServeMux, client HammerClient) error

RegisterHammerHandlerClient registers the http handlers for service Hammer to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "HammerClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "HammerClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "HammerClient" to call the correct interceptors.

func RegisterHammerHandlerFromEndpoint 

func RegisterHammerHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterHammerHandlerFromEndpoint is same as RegisterHammerHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterHammerHandlerServer 

func RegisterHammerHandlerServer(ctx context.Context, mux *runtime.ServeMux, server HammerServer) error

RegisterHammerHandlerServer registers the http handlers for service Hammer to "mux". UnaryRPC :call HammerServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterHammerServer 

func RegisterHammerServer(s *grpc.Server, srv HammerServer)

Types

type CreateMessageRequest 

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

Request for the CreateMessage method

func (*CreateMessageRequest) Descriptor deprecated 

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

Deprecated: Use CreateMessageRequest.ProtoReflect.Descriptor instead.

func (*CreateMessageRequest) GetMessage 

func (x *CreateMessageRequest) GetMessage() *Message

func (*CreateMessageRequest) ProtoMessage 

func (*CreateMessageRequest) ProtoMessage()

func (*CreateMessageRequest) ProtoReflect 

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

func (*CreateMessageRequest) Reset 

func (x *CreateMessageRequest) Reset()

func (*CreateMessageRequest) String 

func (x *CreateMessageRequest) String() string

type CreateSubscriptionRequest 

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

Request for the CreateSubscription method

func (*CreateSubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use CreateSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*CreateSubscriptionRequest) GetSubscription 

func (x *CreateSubscriptionRequest) GetSubscription() *Subscription

func (*CreateSubscriptionRequest) ProtoMessage 

func (*CreateSubscriptionRequest) ProtoMessage()

func (*CreateSubscriptionRequest) ProtoReflect 

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

func (*CreateSubscriptionRequest) Reset 

func (x *CreateSubscriptionRequest) Reset()

func (*CreateSubscriptionRequest) String 

func (x *CreateSubscriptionRequest) String() string

type CreateTopicRequest 

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

Request for the CreateTopic method

func (*CreateTopicRequest) Descriptor deprecated 

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

Deprecated: Use CreateTopicRequest.ProtoReflect.Descriptor instead.

func (*CreateTopicRequest) GetTopic 

func (x *CreateTopicRequest) GetTopic() *Topic

func (*CreateTopicRequest) ProtoMessage 

func (*CreateTopicRequest) ProtoMessage()

func (*CreateTopicRequest) ProtoReflect 

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

func (*CreateTopicRequest) Reset 

func (x *CreateTopicRequest) Reset()

func (*CreateTopicRequest) String 

func (x *CreateTopicRequest) String() string

type DeleteMessageRequest 

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

Request for the DeleteMessage method

func (*DeleteMessageRequest) Descriptor deprecated 

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

Deprecated: Use DeleteMessageRequest.ProtoReflect.Descriptor instead.

func (*DeleteMessageRequest) GetId 

func (x *DeleteMessageRequest) GetId() string

func (*DeleteMessageRequest) ProtoMessage 

func (*DeleteMessageRequest) ProtoMessage()

func (*DeleteMessageRequest) ProtoReflect 

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

func (*DeleteMessageRequest) Reset 

func (x *DeleteMessageRequest) Reset()

func (*DeleteMessageRequest) String 

func (x *DeleteMessageRequest) String() string

type DeleteSubscriptionRequest 

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

Request for the DeleteSubscription method

func (*DeleteSubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use DeleteSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*DeleteSubscriptionRequest) GetId 

func (x *DeleteSubscriptionRequest) GetId() string

func (*DeleteSubscriptionRequest) ProtoMessage 

func (*DeleteSubscriptionRequest) ProtoMessage()

func (*DeleteSubscriptionRequest) ProtoReflect 

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

func (*DeleteSubscriptionRequest) Reset 

func (x *DeleteSubscriptionRequest) Reset()

func (*DeleteSubscriptionRequest) String 

func (x *DeleteSubscriptionRequest) String() string

type DeleteTopicRequest 

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

Request for the DeleteTopic method

func (*DeleteTopicRequest) Descriptor deprecated 

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

Deprecated: Use DeleteTopicRequest.ProtoReflect.Descriptor instead.

func (*DeleteTopicRequest) GetId 

func (x *DeleteTopicRequest) GetId() string

func (*DeleteTopicRequest) ProtoMessage 

func (*DeleteTopicRequest) ProtoMessage()

func (*DeleteTopicRequest) ProtoReflect 

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

func (*DeleteTopicRequest) Reset 

func (x *DeleteTopicRequest) Reset()

func (*DeleteTopicRequest) String 

func (x *DeleteTopicRequest) String() string

type Delivery 

type Delivery struct {
	Id                     string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	TopicId                string               `protobuf:"bytes,2,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"`
	SubscriptionId         string               `protobuf:"bytes,3,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	MessageId              string               `protobuf:"bytes,4,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	ContentType            string               `protobuf:"bytes,5,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	Data                   string               `protobuf:"bytes,6,opt,name=data,proto3" json:"data,omitempty"`
	Url                    string               `protobuf:"bytes,7,opt,name=url,proto3" json:"url,omitempty"`
	SecretToken            string               `protobuf:"bytes,8,opt,name=secret_token,json=secretToken,proto3" json:"secret_token,omitempty"`
	MaxDeliveryAttempts    uint32               `protobuf:"varint,9,opt,name=max_delivery_attempts,json=maxDeliveryAttempts,proto3" json:"max_delivery_attempts,omitempty"`
	DeliveryAttemptDelay   uint32               `protobuf:"varint,10,opt,name=delivery_attempt_delay,json=deliveryAttemptDelay,proto3" json:"delivery_attempt_delay,omitempty"`
	DeliveryAttemptTimeout uint32               `` /* 131-byte string literal not displayed */
	ScheduledAt            *timestamp.Timestamp `protobuf:"bytes,12,opt,name=scheduled_at,json=scheduledAt,proto3" json:"scheduled_at,omitempty"`
	DeliveryAttempts       uint32               `protobuf:"varint,13,opt,name=delivery_attempts,json=deliveryAttempts,proto3" json:"delivery_attempts,omitempty"`
	Status                 string               `protobuf:"bytes,14,opt,name=status,proto3" json:"status,omitempty"`
	CreatedAt              *timestamp.Timestamp `protobuf:"bytes,15,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt              *timestamp.Timestamp `protobuf:"bytes,16,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

A delivery resource

func (*Delivery) Descriptor deprecated 

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

Deprecated: Use Delivery.ProtoReflect.Descriptor instead.

func (*Delivery) GetContentType 

func (x *Delivery) GetContentType() string

func (*Delivery) GetCreatedAt 

func (x *Delivery) GetCreatedAt() *timestamp.Timestamp

func (*Delivery) GetData 

func (x *Delivery) GetData() string

func (*Delivery) GetDeliveryAttemptDelay 

func (x *Delivery) GetDeliveryAttemptDelay() uint32

func (*Delivery) GetDeliveryAttemptTimeout 

func (x *Delivery) GetDeliveryAttemptTimeout() uint32

func (*Delivery) GetDeliveryAttempts 

func (x *Delivery) GetDeliveryAttempts() uint32

func (*Delivery) GetId 

func (x *Delivery) GetId() string

func (*Delivery) GetMaxDeliveryAttempts 

func (x *Delivery) GetMaxDeliveryAttempts() uint32

func (*Delivery) GetMessageId 

func (x *Delivery) GetMessageId() string

func (*Delivery) GetScheduledAt 

func (x *Delivery) GetScheduledAt() *timestamp.Timestamp

func (*Delivery) GetSecretToken 

func (x *Delivery) GetSecretToken() string

func (*Delivery) GetStatus 

func (x *Delivery) GetStatus() string

func (*Delivery) GetSubscriptionId 

func (x *Delivery) GetSubscriptionId() string

func (*Delivery) GetTopicId 

func (x *Delivery) GetTopicId() string

func (*Delivery) GetUpdatedAt 

func (x *Delivery) GetUpdatedAt() *timestamp.Timestamp

func (*Delivery) GetUrl 

func (x *Delivery) GetUrl() string

func (*Delivery) ProtoMessage 

func (*Delivery) ProtoMessage()

func (*Delivery) ProtoReflect 

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

func (*Delivery) Reset 

func (x *Delivery) Reset()

func (*Delivery) String 

func (x *Delivery) String() string

type DeliveryAttempt 

type DeliveryAttempt struct {
	Id                 string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	DeliveryId         string               `protobuf:"bytes,2,opt,name=delivery_id,json=deliveryId,proto3" json:"delivery_id,omitempty"`
	Request            string               `protobuf:"bytes,3,opt,name=request,proto3" json:"request,omitempty"`
	Response           string               `protobuf:"bytes,4,opt,name=response,proto3" json:"response,omitempty"`
	ResponseStatusCode uint32               `protobuf:"varint,5,opt,name=response_status_code,json=responseStatusCode,proto3" json:"response_status_code,omitempty"`
	ExecutionDuration  uint32               `protobuf:"varint,6,opt,name=execution_duration,json=executionDuration,proto3" json:"execution_duration,omitempty"`
	Success            bool                 `protobuf:"varint,7,opt,name=success,proto3" json:"success,omitempty"`
	Error              string               `protobuf:"bytes,8,opt,name=error,proto3" json:"error,omitempty"`
	CreatedAt          *timestamp.Timestamp `protobuf:"bytes,9,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

A delivery attempt resource

func (*DeliveryAttempt) Descriptor deprecated 

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

Deprecated: Use DeliveryAttempt.ProtoReflect.Descriptor instead.

func (*DeliveryAttempt) GetCreatedAt 

func (x *DeliveryAttempt) GetCreatedAt() *timestamp.Timestamp

func (*DeliveryAttempt) GetDeliveryId 

func (x *DeliveryAttempt) GetDeliveryId() string

func (*DeliveryAttempt) GetError 

func (x *DeliveryAttempt) GetError() string

func (*DeliveryAttempt) GetExecutionDuration 

func (x *DeliveryAttempt) GetExecutionDuration() uint32

func (*DeliveryAttempt) GetId 

func (x *DeliveryAttempt) GetId() string

func (*DeliveryAttempt) GetRequest 

func (x *DeliveryAttempt) GetRequest() string

func (*DeliveryAttempt) GetResponse 

func (x *DeliveryAttempt) GetResponse() string

func (*DeliveryAttempt) GetResponseStatusCode 

func (x *DeliveryAttempt) GetResponseStatusCode() uint32

func (*DeliveryAttempt) GetSuccess 

func (x *DeliveryAttempt) GetSuccess() bool

func (*DeliveryAttempt) ProtoMessage 

func (*DeliveryAttempt) ProtoMessage()

func (*DeliveryAttempt) ProtoReflect 

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

func (*DeliveryAttempt) Reset 

func (x *DeliveryAttempt) Reset()

func (*DeliveryAttempt) String 

func (x *DeliveryAttempt) String() string

type GetDeliveryAttemptRequest 

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

Request for the GetDeliveryAttempt method

func (*GetDeliveryAttemptRequest) Descriptor deprecated 

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

Deprecated: Use GetDeliveryAttemptRequest.ProtoReflect.Descriptor instead.

func (*GetDeliveryAttemptRequest) GetId 

func (x *GetDeliveryAttemptRequest) GetId() string

func (*GetDeliveryAttemptRequest) ProtoMessage 

func (*GetDeliveryAttemptRequest) ProtoMessage()

func (*GetDeliveryAttemptRequest) ProtoReflect 

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

func (*GetDeliveryAttemptRequest) Reset 

func (x *GetDeliveryAttemptRequest) Reset()

func (*GetDeliveryAttemptRequest) String 

func (x *GetDeliveryAttemptRequest) String() string

type GetDeliveryRequest 

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

Request for the GetDelivery method

func (*GetDeliveryRequest) Descriptor deprecated 

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

Deprecated: Use GetDeliveryRequest.ProtoReflect.Descriptor instead.

func (*GetDeliveryRequest) GetId 

func (x *GetDeliveryRequest) GetId() string

func (*GetDeliveryRequest) ProtoMessage 

func (*GetDeliveryRequest) ProtoMessage()

func (*GetDeliveryRequest) ProtoReflect 

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

func (*GetDeliveryRequest) Reset 

func (x *GetDeliveryRequest) Reset()

func (*GetDeliveryRequest) String 

func (x *GetDeliveryRequest) String() string

type GetMessageRequest 

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

Request for the GetMessage method

func (*GetMessageRequest) Descriptor deprecated 

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

Deprecated: Use GetMessageRequest.ProtoReflect.Descriptor instead.

func (*GetMessageRequest) GetId 

func (x *GetMessageRequest) GetId() string

func (*GetMessageRequest) ProtoMessage 

func (*GetMessageRequest) ProtoMessage()

func (*GetMessageRequest) ProtoReflect 

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

func (*GetMessageRequest) Reset 

func (x *GetMessageRequest) Reset()

func (*GetMessageRequest) String 

func (x *GetMessageRequest) String() string

type GetSubscriptionRequest 

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

Request for the GetSubscription method

func (*GetSubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use GetSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*GetSubscriptionRequest) GetId 

func (x *GetSubscriptionRequest) GetId() string

func (*GetSubscriptionRequest) ProtoMessage 

func (*GetSubscriptionRequest) ProtoMessage()

func (*GetSubscriptionRequest) ProtoReflect 

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

func (*GetSubscriptionRequest) Reset 

func (x *GetSubscriptionRequest) Reset()

func (*GetSubscriptionRequest) String 

func (x *GetSubscriptionRequest) String() string

type GetTopicRequest 

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

Request for the GetTopic method

func (*GetTopicRequest) Descriptor deprecated 

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

Deprecated: Use GetTopicRequest.ProtoReflect.Descriptor instead.

func (*GetTopicRequest) GetId 

func (x *GetTopicRequest) GetId() string

func (*GetTopicRequest) ProtoMessage 

func (*GetTopicRequest) ProtoMessage()

func (*GetTopicRequest) ProtoReflect 

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

func (*GetTopicRequest) Reset 

func (x *GetTopicRequest) Reset()

func (*GetTopicRequest) String 

func (x *GetTopicRequest) String() string

type HammerClient 

type HammerClient interface {
	// Create a new topic
	CreateTopic(ctx context.Context, in *CreateTopicRequest, opts ...grpc.CallOption) (*Topic, error)
	// Update the topic
	UpdateTopic(ctx context.Context, in *UpdateTopicRequest, opts ...grpc.CallOption) (*Topic, error)
	// Gets the topic
	GetTopic(ctx context.Context, in *GetTopicRequest, opts ...grpc.CallOption) (*Topic, error)
	// List topics
	ListTopics(ctx context.Context, in *ListTopicsRequest, opts ...grpc.CallOption) (*ListTopicsResponse, error)
	// Delete topic
	DeleteTopic(ctx context.Context, in *DeleteTopicRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Create a new subscription
	CreateSubscription(ctx context.Context, in *CreateSubscriptionRequest, opts ...grpc.CallOption) (*Subscription, error)
	// Update the subscription
	UpdateSubscription(ctx context.Context, in *UpdateSubscriptionRequest, opts ...grpc.CallOption) (*Subscription, error)
	// Gets the subscription
	GetSubscription(ctx context.Context, in *GetSubscriptionRequest, opts ...grpc.CallOption) (*Subscription, error)
	// List subscriptions
	ListSubscriptions(ctx context.Context, in *ListSubscriptionsRequest, opts ...grpc.CallOption) (*ListSubscriptionsResponse, error)
	// Delete subscription
	DeleteSubscription(ctx context.Context, in *DeleteSubscriptionRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Create a new message
	CreateMessage(ctx context.Context, in *CreateMessageRequest, opts ...grpc.CallOption) (*Message, error)
	// Gets the message
	GetMessage(ctx context.Context, in *GetMessageRequest, opts ...grpc.CallOption) (*Message, error)
	// List messages
	ListMessages(ctx context.Context, in *ListMessagesRequest, opts ...grpc.CallOption) (*ListMessagesResponse, error)
	// Delete message
	DeleteMessage(ctx context.Context, in *DeleteMessageRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Gets the delivery
	GetDelivery(ctx context.Context, in *GetDeliveryRequest, opts ...grpc.CallOption) (*Delivery, error)
	// List deliveires
	ListDeliveries(ctx context.Context, in *ListDeliveriesRequest, opts ...grpc.CallOption) (*ListDeliveriesResponse, error)
	// Gets the delivery attempt
	GetDeliveryAttempt(ctx context.Context, in *GetDeliveryAttemptRequest, opts ...grpc.CallOption) (*DeliveryAttempt, error)
	// List delivery attempts
	ListDeliveryAttempts(ctx context.Context, in *ListDeliveryAttemptsRequest, opts ...grpc.CallOption) (*ListDeliveryAttemptsResponse, error)
}

HammerClient is the client API for Hammer service.

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

func NewHammerClient 

func NewHammerClient(cc grpc.ClientConnInterface) HammerClient

type HammerServer 

type HammerServer interface {
	// Create a new topic
	CreateTopic(context.Context, *CreateTopicRequest) (*Topic, error)
	// Update the topic
	UpdateTopic(context.Context, *UpdateTopicRequest) (*Topic, error)
	// Gets the topic
	GetTopic(context.Context, *GetTopicRequest) (*Topic, error)
	// List topics
	ListTopics(context.Context, *ListTopicsRequest) (*ListTopicsResponse, error)
	// Delete topic
	DeleteTopic(context.Context, *DeleteTopicRequest) (*empty.Empty, error)
	// Create a new subscription
	CreateSubscription(context.Context, *CreateSubscriptionRequest) (*Subscription, error)
	// Update the subscription
	UpdateSubscription(context.Context, *UpdateSubscriptionRequest) (*Subscription, error)
	// Gets the subscription
	GetSubscription(context.Context, *GetSubscriptionRequest) (*Subscription, error)
	// List subscriptions
	ListSubscriptions(context.Context, *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error)
	// Delete subscription
	DeleteSubscription(context.Context, *DeleteSubscriptionRequest) (*empty.Empty, error)
	// Create a new message
	CreateMessage(context.Context, *CreateMessageRequest) (*Message, error)
	// Gets the message
	GetMessage(context.Context, *GetMessageRequest) (*Message, error)
	// List messages
	ListMessages(context.Context, *ListMessagesRequest) (*ListMessagesResponse, error)
	// Delete message
	DeleteMessage(context.Context, *DeleteMessageRequest) (*empty.Empty, error)
	// Gets the delivery
	GetDelivery(context.Context, *GetDeliveryRequest) (*Delivery, error)
	// List deliveires
	ListDeliveries(context.Context, *ListDeliveriesRequest) (*ListDeliveriesResponse, error)
	// Gets the delivery attempt
	GetDeliveryAttempt(context.Context, *GetDeliveryAttemptRequest) (*DeliveryAttempt, error)
	// List delivery attempts
	ListDeliveryAttempts(context.Context, *ListDeliveryAttemptsRequest) (*ListDeliveryAttemptsResponse, error)
}

HammerServer is the server API for Hammer service.

type ListDeliveriesRequest 

type ListDeliveriesRequest struct {
	Limit          uint32 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset         uint32 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	TopicId        string `protobuf:"bytes,3,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"`
	SubscriptionId string `protobuf:"bytes,4,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	MessageId      string `protobuf:"bytes,5,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	Status         string `protobuf:"bytes,6,opt,name=status,proto3" json:"status,omitempty"`
	CreatedAtGt    string `protobuf:"bytes,7,opt,name=created_at_gt,json=createdAtGt,proto3" json:"created_at_gt,omitempty"`
	CreatedAtGte   string `protobuf:"bytes,8,opt,name=created_at_gte,json=createdAtGte,proto3" json:"created_at_gte,omitempty"`
	CreatedAtLt    string `protobuf:"bytes,9,opt,name=created_at_lt,json=createdAtLt,proto3" json:"created_at_lt,omitempty"`
	CreatedAtLte   string `protobuf:"bytes,10,opt,name=created_at_lte,json=createdAtLte,proto3" json:"created_at_lte,omitempty"`
	// contains filtered or unexported fields
}

Request for the ListDeliveries method

func (*ListDeliveriesRequest) Descriptor deprecated 

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

Deprecated: Use ListDeliveriesRequest.ProtoReflect.Descriptor instead.

func (*ListDeliveriesRequest) GetCreatedAtGt 

func (x *ListDeliveriesRequest) GetCreatedAtGt() string

func (*ListDeliveriesRequest) GetCreatedAtGte 

func (x *ListDeliveriesRequest) GetCreatedAtGte() string

func (*ListDeliveriesRequest) GetCreatedAtLt 

func (x *ListDeliveriesRequest) GetCreatedAtLt() string

func (*ListDeliveriesRequest) GetCreatedAtLte 

func (x *ListDeliveriesRequest) GetCreatedAtLte() string

func (*ListDeliveriesRequest) GetLimit 

func (x *ListDeliveriesRequest) GetLimit() uint32

func (*ListDeliveriesRequest) GetMessageId 

func (x *ListDeliveriesRequest) GetMessageId() string

func (*ListDeliveriesRequest) GetOffset 

func (x *ListDeliveriesRequest) GetOffset() uint32

func (*ListDeliveriesRequest) GetStatus 

func (x *ListDeliveriesRequest) GetStatus() string

func (*ListDeliveriesRequest) GetSubscriptionId 

func (x *ListDeliveriesRequest) GetSubscriptionId() string

func (*ListDeliveriesRequest) GetTopicId 

func (x *ListDeliveriesRequest) GetTopicId() string

func (*ListDeliveriesRequest) ProtoMessage 

func (*ListDeliveriesRequest) ProtoMessage()

func (*ListDeliveriesRequest) ProtoReflect 

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

func (*ListDeliveriesRequest) Reset 

func (x *ListDeliveriesRequest) Reset()

func (*ListDeliveriesRequest) String 

func (x *ListDeliveriesRequest) String() string

type ListDeliveriesResponse 

type ListDeliveriesResponse struct {
	Deliveries []*Delivery `protobuf:"bytes,1,rep,name=deliveries,proto3" json:"deliveries,omitempty"`
	// contains filtered or unexported fields
}

Response for the ListDeliveries method

func (*ListDeliveriesResponse) Descriptor deprecated 

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

Deprecated: Use ListDeliveriesResponse.ProtoReflect.Descriptor instead.

func (*ListDeliveriesResponse) GetDeliveries 

func (x *ListDeliveriesResponse) GetDeliveries() []*Delivery

func (*ListDeliveriesResponse) ProtoMessage 

func (*ListDeliveriesResponse) ProtoMessage()

func (*ListDeliveriesResponse) ProtoReflect 

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

func (*ListDeliveriesResponse) Reset 

func (x *ListDeliveriesResponse) Reset()

func (*ListDeliveriesResponse) String 

func (x *ListDeliveriesResponse) String() string

type ListDeliveryAttemptsRequest 

type ListDeliveryAttemptsRequest struct {
	Limit        uint32 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset       uint32 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	DeliveryId   string `protobuf:"bytes,3,opt,name=delivery_id,json=deliveryId,proto3" json:"delivery_id,omitempty"`
	CreatedAtGt  string `protobuf:"bytes,4,opt,name=created_at_gt,json=createdAtGt,proto3" json:"created_at_gt,omitempty"`
	CreatedAtGte string `protobuf:"bytes,5,opt,name=created_at_gte,json=createdAtGte,proto3" json:"created_at_gte,omitempty"`
	CreatedAtLt  string `protobuf:"bytes,6,opt,name=created_at_lt,json=createdAtLt,proto3" json:"created_at_lt,omitempty"`
	CreatedAtLte string `protobuf:"bytes,7,opt,name=created_at_lte,json=createdAtLte,proto3" json:"created_at_lte,omitempty"`
	// contains filtered or unexported fields
}

Request for the ListDeliveryAttempts method

func (*ListDeliveryAttemptsRequest) Descriptor deprecated 

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

Deprecated: Use ListDeliveryAttemptsRequest.ProtoReflect.Descriptor instead.

func (*ListDeliveryAttemptsRequest) GetCreatedAtGt 

func (x *ListDeliveryAttemptsRequest) GetCreatedAtGt() string

func (*ListDeliveryAttemptsRequest) GetCreatedAtGte 

func (x *ListDeliveryAttemptsRequest) GetCreatedAtGte() string

func (*ListDeliveryAttemptsRequest) GetCreatedAtLt 

func (x *ListDeliveryAttemptsRequest) GetCreatedAtLt() string

func (*ListDeliveryAttemptsRequest) GetCreatedAtLte 

func (x *ListDeliveryAttemptsRequest) GetCreatedAtLte() string

func (*ListDeliveryAttemptsRequest) GetDeliveryId 

func (x *ListDeliveryAttemptsRequest) GetDeliveryId() string

func (*ListDeliveryAttemptsRequest) GetLimit 

func (x *ListDeliveryAttemptsRequest) GetLimit() uint32

func (*ListDeliveryAttemptsRequest) GetOffset 

func (x *ListDeliveryAttemptsRequest) GetOffset() uint32

func (*ListDeliveryAttemptsRequest) ProtoMessage 

func (*ListDeliveryAttemptsRequest) ProtoMessage()

func (*ListDeliveryAttemptsRequest) ProtoReflect 

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

func (*ListDeliveryAttemptsRequest) Reset 

func (x *ListDeliveryAttemptsRequest) Reset()

func (*ListDeliveryAttemptsRequest) String 

func (x *ListDeliveryAttemptsRequest) String() string

type ListDeliveryAttemptsResponse 

type ListDeliveryAttemptsResponse struct {
	DeliveryAttempts []*DeliveryAttempt `protobuf:"bytes,1,rep,name=delivery_attempts,json=deliveryAttempts,proto3" json:"delivery_attempts,omitempty"`
	// contains filtered or unexported fields
}

Response for the ListDeliveryAttempts method

func (*ListDeliveryAttemptsResponse) Descriptor deprecated 

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

Deprecated: Use ListDeliveryAttemptsResponse.ProtoReflect.Descriptor instead.

func (*ListDeliveryAttemptsResponse) GetDeliveryAttempts 

func (x *ListDeliveryAttemptsResponse) GetDeliveryAttempts() []*DeliveryAttempt

func (*ListDeliveryAttemptsResponse) ProtoMessage 

func (*ListDeliveryAttemptsResponse) ProtoMessage()

func (*ListDeliveryAttemptsResponse) ProtoReflect 

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

func (*ListDeliveryAttemptsResponse) Reset 

func (x *ListDeliveryAttemptsResponse) Reset()

func (*ListDeliveryAttemptsResponse) String 

func (x *ListDeliveryAttemptsResponse) String() string

type ListMessagesRequest 

type ListMessagesRequest struct {
	Limit        uint32 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset       uint32 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	TopicId      string `protobuf:"bytes,3,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"`
	CreatedAtGt  string `protobuf:"bytes,4,opt,name=created_at_gt,json=createdAtGt,proto3" json:"created_at_gt,omitempty"`
	CreatedAtGte string `protobuf:"bytes,5,opt,name=created_at_gte,json=createdAtGte,proto3" json:"created_at_gte,omitempty"`
	CreatedAtLt  string `protobuf:"bytes,6,opt,name=created_at_lt,json=createdAtLt,proto3" json:"created_at_lt,omitempty"`
	CreatedAtLte string `protobuf:"bytes,7,opt,name=created_at_lte,json=createdAtLte,proto3" json:"created_at_lte,omitempty"`
	// contains filtered or unexported fields
}

Request for the ListMessages method

func (*ListMessagesRequest) Descriptor deprecated 

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

Deprecated: Use ListMessagesRequest.ProtoReflect.Descriptor instead.

func (*ListMessagesRequest) GetCreatedAtGt 

func (x *ListMessagesRequest) GetCreatedAtGt() string

func (*ListMessagesRequest) GetCreatedAtGte 

func (x *ListMessagesRequest) GetCreatedAtGte() string

func (*ListMessagesRequest) GetCreatedAtLt 

func (x *ListMessagesRequest) GetCreatedAtLt() string

func (*ListMessagesRequest) GetCreatedAtLte 

func (x *ListMessagesRequest) GetCreatedAtLte() string

func (*ListMessagesRequest) GetLimit 

func (x *ListMessagesRequest) GetLimit() uint32

func (*ListMessagesRequest) GetOffset 

func (x *ListMessagesRequest) GetOffset() uint32

func (*ListMessagesRequest) GetTopicId 

func (x *ListMessagesRequest) GetTopicId() string

func (*ListMessagesRequest) ProtoMessage 

func (*ListMessagesRequest) ProtoMessage()

func (*ListMessagesRequest) ProtoReflect 

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

func (*ListMessagesRequest) Reset 

func (x *ListMessagesRequest) Reset()

func (*ListMessagesRequest) String 

func (x *ListMessagesRequest) String() string

type ListMessagesResponse 

type ListMessagesResponse struct {
	Messages []*Message `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

Response for the ListMessages method

func (*ListMessagesResponse) Descriptor deprecated 

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

Deprecated: Use ListMessagesResponse.ProtoReflect.Descriptor instead.

func (*ListMessagesResponse) GetMessages 

func (x *ListMessagesResponse) GetMessages() []*Message

func (*ListMessagesResponse) ProtoMessage 

func (*ListMessagesResponse) ProtoMessage()

func (*ListMessagesResponse) ProtoReflect 

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

func (*ListMessagesResponse) Reset 

func (x *ListMessagesResponse) Reset()

func (*ListMessagesResponse) String 

func (x *ListMessagesResponse) String() string

type ListSubscriptionsRequest 

type ListSubscriptionsRequest struct {
	Limit        uint32 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset       uint32 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	CreatedAtGt  string `protobuf:"bytes,3,opt,name=created_at_gt,json=createdAtGt,proto3" json:"created_at_gt,omitempty"`
	CreatedAtGte string `protobuf:"bytes,4,opt,name=created_at_gte,json=createdAtGte,proto3" json:"created_at_gte,omitempty"`
	CreatedAtLt  string `protobuf:"bytes,5,opt,name=created_at_lt,json=createdAtLt,proto3" json:"created_at_lt,omitempty"`
	CreatedAtLte string `protobuf:"bytes,6,opt,name=created_at_lte,json=createdAtLte,proto3" json:"created_at_lte,omitempty"`
	// contains filtered or unexported fields
}

Request for the ListSubscriptions method

func (*ListSubscriptionsRequest) Descriptor deprecated 

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

Deprecated: Use ListSubscriptionsRequest.ProtoReflect.Descriptor instead.

func (*ListSubscriptionsRequest) GetCreatedAtGt 

func (x *ListSubscriptionsRequest) GetCreatedAtGt() string

func (*ListSubscriptionsRequest) GetCreatedAtGte 

func (x *ListSubscriptionsRequest) GetCreatedAtGte() string

func (*ListSubscriptionsRequest) GetCreatedAtLt 

func (x *ListSubscriptionsRequest) GetCreatedAtLt() string

func (*ListSubscriptionsRequest) GetCreatedAtLte 

func (x *ListSubscriptionsRequest) GetCreatedAtLte() string

func (*ListSubscriptionsRequest) GetLimit 

func (x *ListSubscriptionsRequest) GetLimit() uint32

func (*ListSubscriptionsRequest) GetOffset 

func (x *ListSubscriptionsRequest) GetOffset() uint32

func (*ListSubscriptionsRequest) ProtoMessage 

func (*ListSubscriptionsRequest) ProtoMessage()

func (*ListSubscriptionsRequest) ProtoReflect 

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

func (*ListSubscriptionsRequest) Reset 

func (x *ListSubscriptionsRequest) Reset()

func (*ListSubscriptionsRequest) String 

func (x *ListSubscriptionsRequest) String() string

type ListSubscriptionsResponse 

type ListSubscriptionsResponse struct {
	Subscriptions []*Subscription `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// contains filtered or unexported fields
}

Response for the ListSubscriptions method

func (*ListSubscriptionsResponse) Descriptor deprecated 

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

Deprecated: Use ListSubscriptionsResponse.ProtoReflect.Descriptor instead.

func (*ListSubscriptionsResponse) GetSubscriptions 

func (x *ListSubscriptionsResponse) GetSubscriptions() []*Subscription

func (*ListSubscriptionsResponse) ProtoMessage 

func (*ListSubscriptionsResponse) ProtoMessage()

func (*ListSubscriptionsResponse) ProtoReflect 

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

func (*ListSubscriptionsResponse) Reset 

func (x *ListSubscriptionsResponse) Reset()

func (*ListSubscriptionsResponse) String 

func (x *ListSubscriptionsResponse) String() string

type ListTopicsRequest 

type ListTopicsRequest struct {
	Limit        uint32 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset       uint32 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	CreatedAtGt  string `protobuf:"bytes,3,opt,name=created_at_gt,json=createdAtGt,proto3" json:"created_at_gt,omitempty"`
	CreatedAtGte string `protobuf:"bytes,4,opt,name=created_at_gte,json=createdAtGte,proto3" json:"created_at_gte,omitempty"`
	CreatedAtLt  string `protobuf:"bytes,5,opt,name=created_at_lt,json=createdAtLt,proto3" json:"created_at_lt,omitempty"`
	CreatedAtLte string `protobuf:"bytes,6,opt,name=created_at_lte,json=createdAtLte,proto3" json:"created_at_lte,omitempty"`
	// contains filtered or unexported fields
}

Request for the ListTopics method

func (*ListTopicsRequest) Descriptor deprecated 

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

Deprecated: Use ListTopicsRequest.ProtoReflect.Descriptor instead.

func (*ListTopicsRequest) GetCreatedAtGt 

func (x *ListTopicsRequest) GetCreatedAtGt() string

func (*ListTopicsRequest) GetCreatedAtGte 

func (x *ListTopicsRequest) GetCreatedAtGte() string

func (*ListTopicsRequest) GetCreatedAtLt 

func (x *ListTopicsRequest) GetCreatedAtLt() string

func (*ListTopicsRequest) GetCreatedAtLte 

func (x *ListTopicsRequest) GetCreatedAtLte() string

func (*ListTopicsRequest) GetLimit 

func (x *ListTopicsRequest) GetLimit() uint32

func (*ListTopicsRequest) GetOffset 

func (x *ListTopicsRequest) GetOffset() uint32

func (*ListTopicsRequest) ProtoMessage 

func (*ListTopicsRequest) ProtoMessage()

func (*ListTopicsRequest) ProtoReflect 

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

func (*ListTopicsRequest) Reset 

func (x *ListTopicsRequest) Reset()

func (*ListTopicsRequest) String 

func (x *ListTopicsRequest) String() string

type ListTopicsResponse 

type ListTopicsResponse struct {
	Topics []*Topic `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
	// contains filtered or unexported fields
}

Response for the ListTopics method

func (*ListTopicsResponse) Descriptor deprecated 

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

Deprecated: Use ListTopicsResponse.ProtoReflect.Descriptor instead.

func (*ListTopicsResponse) GetTopics 

func (x *ListTopicsResponse) GetTopics() []*Topic

func (*ListTopicsResponse) ProtoMessage 

func (*ListTopicsResponse) ProtoMessage()

func (*ListTopicsResponse) ProtoReflect 

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

func (*ListTopicsResponse) Reset 

func (x *ListTopicsResponse) Reset()

func (*ListTopicsResponse) String 

func (x *ListTopicsResponse) String() string

type Message 

type Message struct {
	Id          string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	TopicId     string               `protobuf:"bytes,2,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"`
	ContentType string               `protobuf:"bytes,3,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	Data        string               `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	CreatedAt   *timestamp.Timestamp `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

A message resource

func (*Message) Descriptor deprecated 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetContentType 

func (x *Message) GetContentType() string

func (*Message) GetCreatedAt 

func (x *Message) GetCreatedAt() *timestamp.Timestamp

func (*Message) GetData 

func (x *Message) GetData() string

func (*Message) GetId 

func (x *Message) GetId() string

func (*Message) GetTopicId 

func (x *Message) GetTopicId() string

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 Subscription 

type Subscription struct {
	Id                     string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	TopicId                string               `protobuf:"bytes,2,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"`
	Name                   string               `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Url                    string               `protobuf:"bytes,4,opt,name=url,proto3" json:"url,omitempty"`
	SecretToken            string               `protobuf:"bytes,5,opt,name=secret_token,json=secretToken,proto3" json:"secret_token,omitempty"`
	MaxDeliveryAttempts    uint32               `protobuf:"varint,6,opt,name=max_delivery_attempts,json=maxDeliveryAttempts,proto3" json:"max_delivery_attempts,omitempty"`
	DeliveryAttemptDelay   uint32               `protobuf:"varint,7,opt,name=delivery_attempt_delay,json=deliveryAttemptDelay,proto3" json:"delivery_attempt_delay,omitempty"`
	DeliveryAttemptTimeout uint32               `` /* 130-byte string literal not displayed */
	CreatedAt              *timestamp.Timestamp `protobuf:"bytes,9,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt              *timestamp.Timestamp `protobuf:"bytes,10,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

A subscription resource

func (*Subscription) Descriptor deprecated 

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

Deprecated: Use Subscription.ProtoReflect.Descriptor instead.

func (*Subscription) GetCreatedAt 

func (x *Subscription) GetCreatedAt() *timestamp.Timestamp

func (*Subscription) GetDeliveryAttemptDelay 

func (x *Subscription) GetDeliveryAttemptDelay() uint32

func (*Subscription) GetDeliveryAttemptTimeout 

func (x *Subscription) GetDeliveryAttemptTimeout() uint32

func (*Subscription) GetId 

func (x *Subscription) GetId() string

func (*Subscription) GetMaxDeliveryAttempts 

func (x *Subscription) GetMaxDeliveryAttempts() uint32

func (*Subscription) GetName 

func (x *Subscription) GetName() string

func (*Subscription) GetSecretToken 

func (x *Subscription) GetSecretToken() string

func (*Subscription) GetTopicId 

func (x *Subscription) GetTopicId() string

func (*Subscription) GetUpdatedAt 

func (x *Subscription) GetUpdatedAt() *timestamp.Timestamp

func (*Subscription) GetUrl 

func (x *Subscription) GetUrl() string

func (*Subscription) ProtoMessage 

func (*Subscription) ProtoMessage()

func (*Subscription) ProtoReflect 

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

func (*Subscription) Reset 

func (x *Subscription) Reset()

func (*Subscription) String 

func (x *Subscription) String() string

type Topic 

type Topic struct {
	Id        string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name      string               `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	CreatedAt *timestamp.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt *timestamp.Timestamp `protobuf:"bytes,4,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

A topic resource

func (*Topic) Descriptor deprecated 

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

Deprecated: Use Topic.ProtoReflect.Descriptor instead.

func (*Topic) GetCreatedAt 

func (x *Topic) GetCreatedAt() *timestamp.Timestamp

func (*Topic) GetId 

func (x *Topic) GetId() string

func (*Topic) GetName 

func (x *Topic) GetName() string

func (*Topic) GetUpdatedAt 

func (x *Topic) GetUpdatedAt() *timestamp.Timestamp

func (*Topic) ProtoMessage 

func (*Topic) ProtoMessage()

func (*Topic) ProtoReflect 

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

func (*Topic) Reset 

func (x *Topic) Reset()

func (*Topic) String 

func (x *Topic) String() string

type UnimplementedHammerServer 

type UnimplementedHammerServer struct {
}

UnimplementedHammerServer can be embedded to have forward compatible implementations.

func (*UnimplementedHammerServer) CreateMessage 

func (*UnimplementedHammerServer) CreateMessage(context.Context, *CreateMessageRequest) (*Message, error)

func (*UnimplementedHammerServer) CreateSubscription 

func (*UnimplementedHammerServer) CreateSubscription(context.Context, *CreateSubscriptionRequest) (*Subscription, error)

func (*UnimplementedHammerServer) CreateTopic 

func (*UnimplementedHammerServer) CreateTopic(context.Context, *CreateTopicRequest) (*Topic, error)

func (*UnimplementedHammerServer) DeleteMessage 

func (*UnimplementedHammerServer) DeleteMessage(context.Context, *DeleteMessageRequest) (*empty.Empty, error)

func (*UnimplementedHammerServer) DeleteSubscription 

func (*UnimplementedHammerServer) DeleteSubscription(context.Context, *DeleteSubscriptionRequest) (*empty.Empty, error)

func (*UnimplementedHammerServer) DeleteTopic 

func (*UnimplementedHammerServer) DeleteTopic(context.Context, *DeleteTopicRequest) (*empty.Empty, error)

func (*UnimplementedHammerServer) GetDelivery 

func (*UnimplementedHammerServer) GetDelivery(context.Context, *GetDeliveryRequest) (*Delivery, error)

func (*UnimplementedHammerServer) GetDeliveryAttempt 

func (*UnimplementedHammerServer) GetDeliveryAttempt(context.Context, *GetDeliveryAttemptRequest) (*DeliveryAttempt, error)

func (*UnimplementedHammerServer) GetMessage 

func (*UnimplementedHammerServer) GetMessage(context.Context, *GetMessageRequest) (*Message, error)

func (*UnimplementedHammerServer) GetSubscription 

func (*UnimplementedHammerServer) GetSubscription(context.Context, *GetSubscriptionRequest) (*Subscription, error)

func (*UnimplementedHammerServer) GetTopic 

func (*UnimplementedHammerServer) GetTopic(context.Context, *GetTopicRequest) (*Topic, error)

func (*UnimplementedHammerServer) ListDeliveries 

func (*UnimplementedHammerServer) ListDeliveries(context.Context, *ListDeliveriesRequest) (*ListDeliveriesResponse, error)

func (*UnimplementedHammerServer) ListDeliveryAttempts 

func (*UnimplementedHammerServer) ListDeliveryAttempts(context.Context, *ListDeliveryAttemptsRequest) (*ListDeliveryAttemptsResponse, error)

func (*UnimplementedHammerServer) ListMessages 

func (*UnimplementedHammerServer) ListMessages(context.Context, *ListMessagesRequest) (*ListMessagesResponse, error)

func (*UnimplementedHammerServer) ListSubscriptions 

func (*UnimplementedHammerServer) ListSubscriptions(context.Context, *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error)

func (*UnimplementedHammerServer) ListTopics 

func (*UnimplementedHammerServer) ListTopics(context.Context, *ListTopicsRequest) (*ListTopicsResponse, error)

func (*UnimplementedHammerServer) UpdateSubscription 

func (*UnimplementedHammerServer) UpdateSubscription(context.Context, *UpdateSubscriptionRequest) (*Subscription, error)

func (*UnimplementedHammerServer) UpdateTopic 

func (*UnimplementedHammerServer) UpdateTopic(context.Context, *UpdateTopicRequest) (*Topic, error)

type UpdateSubscriptionRequest 

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

Request for the UpdateSubscription method

func (*UpdateSubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use UpdateSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*UpdateSubscriptionRequest) GetSubscription 

func (x *UpdateSubscriptionRequest) GetSubscription() *Subscription

func (*UpdateSubscriptionRequest) ProtoMessage 

func (*UpdateSubscriptionRequest) ProtoMessage()

func (*UpdateSubscriptionRequest) ProtoReflect 

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

func (*UpdateSubscriptionRequest) Reset 

func (x *UpdateSubscriptionRequest) Reset()

func (*UpdateSubscriptionRequest) String 

func (x *UpdateSubscriptionRequest) String() string

type UpdateTopicRequest 

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

Request for the UpdateTopic method

func (*UpdateTopicRequest) Descriptor deprecated 

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

Deprecated: Use UpdateTopicRequest.ProtoReflect.Descriptor instead.

func (*UpdateTopicRequest) GetTopic 

func (x *UpdateTopicRequest) GetTopic() *Topic

func (*UpdateTopicRequest) ProtoMessage 

func (*UpdateTopicRequest) ProtoMessage()

func (*UpdateTopicRequest) ProtoReflect 

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

func (*UpdateTopicRequest) Reset 

func (x *UpdateTopicRequest) Reset()

func (*UpdateTopicRequest) String 

func (x *UpdateTopicRequest) String() string

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.